private boolean closed;
    private boolean inputFinished;

    /*
        The song and dance with Action<Runnable> is to ease testing.
        See DisconnectableInputStreamTest
     */

    static class ThreadExecuter implements Action<Runnable> {
        @Override
        public void execute(Runnable runnable) {
            Thread thread = new Thread(runnable);
            thread.setName("DisconnectableInputStream source reader");

        assertThat(instr.read(new byte[10], 2, 5), equalTo(-1))
    }

    @Test
    void threadExecuterExecutesTheAction() {
        def e = new DisconnectableInputStream.ThreadExecuter()
        def latch = new CountDownLatch(1)

        e.execute {
            def t = Thread.currentThread()
            assert t.daemon
            latch.countDown()
        }

Class <org.gradle.util.internal.DisconnectableInputStream$1> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (DisconnectableInputStream.java:0)
Class <org.gradle.util.internal.DisconnectableInputStream$ThreadExecuter> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (DisconnectableInputStream.java:0)