private static void writePath(Encoder encoder, boolean isRoot, FileSystemLocationSnapshot snapshot) throws IOException {
        encoder.writeString(isRoot ? snapshot.getAbsolutePath() : snapshot.getName());
    }

    private static EntryType readEntryType(Decoder decoder) throws IOException {
        return EntryType.values()[decoder.readByte()];
    }

    private static void writeEntryType(Encoder encoder, EntryType type) throws IOException {

        encoder.writeBoolean(false);
        writeVariantReference(encoder, state);
        ResolvedGraphVariant externalVariant = variant.getExternalVariant();
        if (externalVariant == null) {
            encoder.writeBoolean(false);
        } else {
            encoder.writeBoolean(true);

            protected void writeAdditionalData(Encoder encoder, ImplementationSnapshot implementationSnapshot) throws Exception {
                LambdaImplementationSnapshot serLambda = (LambdaImplementationSnapshot) implementationSnapshot;
                hashCodeSerializer.write(encoder, serLambda.getClassLoaderHash());
                encoder.writeString(serLambda.getFunctionalInterfaceClass());
                encoder.writeString(serLambda.getImplClass());

        encodeStrings(encoder, spec.getDisallowedClassNames());
        encodeStrings(encoder, spec.getPackagePrefixes());
        encodeStrings(encoder, spec.getDisallowedPackagePrefixes());
        encodeStrings(encoder, spec.getPackageNames());
        encodeStrings(encoder, spec.getResourceNames());
        encodeStrings(encoder, spec.getResourcePrefixes());
    }

    }

    @Override
    public void write(Encoder encoder, IvyArtifactName value) throws IOException {
        encoder.writeString(value.getName());
        encoder.writeString(value.getType());
        encoder.writeNullableString(value.getExtension());
        encoder.writeNullableString(value.getClassifier());
    }

    public void writeNullable(Encoder encoder, @Nullable IvyArtifactName value) throws IOException {

                writeAddresses(encoder, infosSize, addresses);
                writeDaemonInfos(encoder, infosMap, addresses);
                writeStopEvents(encoder, registry);
            } else {
                encoder.writeBoolean(false);
            }
        }

        private void writeStopEvents(Encoder encoder, DaemonRegistryContent registry) throws Exception {

    @Override
    public void write(Encoder encoder, TransportableActionExecutionSpec spec) throws Exception {
        encoder.writeString(spec.getImplementationClassName());
        encoder.writeBoolean(spec.isInternalServicesRequired());
        encoder.writeString(spec.getBaseDir().getAbsolutePath());
        encoder.writeString(spec.getProjectCacheDir().getAbsolutePath());
        encoder.writeBinary(spec.getSerializedParameters());

        private final Map<ChannelIdentifier, Integer> channels = new HashMap<ChannelIdentifier, Integer>();
        private final Encoder encoder;
        private final ObjectWriter<Object> payloadWriter;

        public MessageWriter(Encoder encoder, ObjectWriter<Object> payloadWriter) {
            this.encoder = encoder;
            this.payloadWriter = payloadWriter;
        }

        @Override

    def "can encode and decode binary content"() {
        def outputStream = new ByteArrayOutputStream()
        def encoder = new EncodedStream.EncodedOutput(outputStream)

        when:
        encoder.write(0)
        encoder.write(127)
        encoder.write(128)
        encoder.write(255)
        encoder.flush()

        then:
        def inputStream = new ByteArrayInputStream(outputStream.toByteArray())

                    encoder.writeSmallInt(id);
                    encoder.writeString(includeFileState.getIncludePath());
                    if (includeFileState.getIncludedBy() == null) {
                        encoder.writeBoolean(false);
                    } else {
                        encoder.writeBoolean(true);
                        hashSerializer.write(encoder, includeFileState.getIncludedBy());