import org.gradle.launcher.daemon.diagnostics.DaemonDiagnostics;
import org.gradle.launcher.daemon.diagnostics.DaemonStartupInfo;
import org.gradle.launcher.daemon.logging.DaemonMessages;

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

        executorServiceTypeOnCurrentJvm() | Executor         | "java.util.concurrent.Executors.newSingleThreadExecutor().tap { shutdown() }"
        ByteArrayInputStream              | InputStream      | "new java.io.ByteArrayInputStream([] as byte[])"
        ByteArrayOutputStream             | OutputStream     | "new java.io.ByteArrayOutputStream()"

        def stream = new ByteArrayOutputStream()
        def encoder = new KryoBackedEncoder(stream)
        encoder.writeString(text)
        encoder.writeInt(12)
        encoder.flush()
        return new ByteArrayInputStream(stream.toByteArray())
    }

        def output = new ByteArrayOutputStream()
        def oos = new ObjectOutputStream(output)
        oos.writeObject(arrayObject)
        oos.close()

        when:
        def input = new ByteArrayInputStream(output.toByteArray())
        def ois = new ClassLoaderObjectInputStream(input, gcl)
        def readArrayObject = ois.readObject()

        then:
        readArrayObject.class.isArray()

        return fromBytes(bytes, serializer)
    }

    <T> T fromBytes(byte[] bytes, Serializer<T> serializer) {
        return serializer.read(getDecoder().newInstance(new ByteArrayInputStream(bytes)))
    }

    <T> byte[] toBytes(T value, Serializer<T> serializer) {
        def bytes = new ByteArrayOutputStream()
        def encoder = getEncoder().newInstance(bytes)

            names.each {
                serializer.write(encoder, it)
            }
        }
        def bytes = out.toByteArray()
        def decoder = new KryoBackedDecoder(new ByteArrayInputStream(bytes))
        def result = []
        names.each {
            result << deserializer.read(decoder)
        }

        then:
        result == names

    }

    private ResolvedComponentResult deserialize(byte[] serialized) {
        def builder = new ResolutionResultGraphBuilder()
        serializer.readInto(new KryoBackedDecoder(new ByteArrayInputStream(serialized)), builder)
        return builder.getRoot(0)
    }

    private Capability capability(String name) {
        Mock(Capability) {
            getGroup() >> 'org'
            getName() >> name

        when:
        encoder.close()

        then:
        encoder.writePosition == 4108
        outstr.size() == 4108

        when:
        def instr = new ByteArrayInputStream(outstr.toByteArray())
        def decoder = new KryoBackedDecoder(instr)

        then:
        instr.available() == 4108
        decoder.readPosition == 0

        when: