import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;

public class DaemonStartupCommunication {

    private static final Logger LOGGER = Logging.getLogger(DaemonStartupCommunication.class);

    @SuppressWarnings("DefaultCharset")
    public void printDaemonStarted(PrintStream target, Long pid, String uid, Address address, File daemonLog) {

        this.documentationRegistry = documentationRegistry;
    }

    public DaemonStartupInfo parseDaemonOutput(String output, List<String> startupArgs) {
        DaemonStartupCommunication startupCommunication = new DaemonStartupCommunication();
        if (!startupCommunication.containsGreeting(output)) {
            throw new GradleException(prepareMessage(output, startupArgs));
        }

import java.util.concurrent.Executor;

public class DaemonOutputConsumer implements StreamsHandler {

    private final static Logger LOGGER = Logging.getLogger(DaemonOutputConsumer.class);
    DaemonStartupCommunication startupCommunication = new DaemonStartupCommunication();

    private String processOutput;
    private InputStream processStdOutput;

    @Override
    public void connectStreams(Process process, String processName, Executor executor) {

import org.gradle.internal.remote.internal.inet.MultiChoiceAddress
import spock.lang.Specification

class DaemonStartupCommunicationSpec extends Specification {
    def comm = new DaemonStartupCommunication()
    def dummyFile = new File("C:\\foo;;\\daemon-123.log\n\r\n\u03b1")
    def uuid = UUID.randomUUID()
    def addresses = [InetAddress.getByName(null)]

    def "can simply communicate diagnostics"() {

           Hey!
           Come visit Krakow
           It's nice
           !!!
        """
        def process = process(output)

        given:
        consumer.startupCommunication = Mock(DaemonStartupCommunication)
        consumer.startupCommunication.containsGreeting({ it.contains "Come visit Krakow" }) >> true

        when:
        consumer.connectStreams(process, "cool process", executor)
        consumer.start()

        def outputStream = new ByteArrayOutputStream()
        def printStream = new PrintStream(outputStream)
        printStream.print("""hey joe!
another line of output...
""")

        new DaemonStartupCommunication().printDaemonStarted(printStream, 12, "uid", address, new File("12.log"))
        def output = new String(outputStream.toByteArray())

        when:

        System.exit(1);
    }

    protected void daemonStarted(Long pid, String uid, Address address, File daemonLog) {
        // directly printing to the stream to avoid log level filtering.
        new DaemonStartupCommunication().printDaemonStarted(originalOut, pid, uid, address, daemonLog);
        try {
            originalOut.close();
            originalErr.close();
        } finally {
            originalOut = null;

Class <org.gradle.launcher.daemon.bootstrap.DaemonStartupCommunication> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (DaemonStartupCommunication.java:0)