@Override
    void encodeTo(OutputStream outputStream, Closure<Encoder> closure) {
        def encoder = new OutputStreamBackedEncoder(outputStream)
        closure.call(encoder)
    }

    @Override
    void decodeFrom(InputStream inputStream, Closure<Decoder> closure) {
        def decoder = new InputStreamBackedDecoder(inputStream)
        closure.call(decoder)
    }

            return [] as byte[]
        }
        return result[0..result.length - 2] as byte[]
    }

    abstract void decodeFrom(InputStream inputStream, Closure<Decoder> closure)

    void decode(byte[] bytes, Closure<Decoder> closure) {
        decodeFrom(new ByteArrayInputStream(bytes), closure)
    }

        def encoder = new KryoBackedEncoder(outputStream, 10)
        closure.call(encoder)
        encoder.flush()
    }

    @Override
    void decodeFrom(InputStream inputStream, Closure<Decoder> closure) {
        def decoder = new KryoBackedDecoder(inputStream, 10)
        closure.call(decoder)
    }

    def "can encode and decode empty byte stream"() {
        when: