tchannel-core/src/main/java/com/uber/tchannel/frames/CallRequestContinueFrame.java [50:93]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public ByteBuf encodeHeader(ByteBufAllocator allocator) {

        ByteBuf buffer = allocator.buffer(2, 6);
        boolean release = true;
        try {
            // flags:1
            buffer.writeByte(getFlags());

            // csumtype:1
            buffer.writeByte(getChecksumType().byteValue());

            // checksum -> (csum:4){0,1}
            CodecUtils.encodeChecksum(getChecksum(), getChecksumType(), buffer);
            release = false;
        } finally {
            if (release) {
                buffer.release();
            }
        }

        return buffer;
    }

    @Override
    public void decode(TFrame tFrame) {

        // flags:1
        flags = tFrame.payload.readByte();

        // csumtype:1
        checksumType = ChecksumType.fromByte(tFrame.payload.readByte());

        // (csum:4){0,1}
        checksum = CodecUtils.decodeChecksum(checksumType, tFrame.payload);

        // {continuation}
        int payloadSize = tFrame.size - tFrame.payload.readerIndex();
        payload = tFrame.payload.readSlice(payloadSize);
    }

    @Override
    public ByteBufHolder replace(ByteBuf payload) {
        return new CallRequestContinueFrame(this.id, this.flags, this.checksumType, this.checksum, payload);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tchannel-core/src/main/java/com/uber/tchannel/frames/CallResponseContinueFrame.java [54:97]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public ByteBuf encodeHeader(ByteBufAllocator allocator) {
        ByteBuf buffer = allocator.buffer(2, 6);

        boolean release = true;
        try {
            // flags:1
            buffer.writeByte(getFlags());

            // csumtype:1
            buffer.writeByte(getChecksumType().byteValue());

            // checksum -> (csum:4){0,1}
            CodecUtils.encodeChecksum(getChecksum(), getChecksumType(), buffer);
            release = false;
        } finally {
            if (release) {
                buffer.release();
            }
        }

        return buffer;
    }

    @Override
    public void decode(TFrame tFrame) {

        // flags:1
        flags = tFrame.payload.readByte();

        // csumtype:1
        checksumType = ChecksumType.fromByte(tFrame.payload.readByte());

        // (csum:4){0,1}
        checksum = CodecUtils.decodeChecksum(checksumType, tFrame.payload);

        // {continuation}
        int payloadSize = tFrame.size - tFrame.payload.readerIndex();
        payload = tFrame.payload.readSlice(payloadSize);
    }

    @Override
    public ByteBufHolder replace(ByteBuf payload) {
        return new CallRequestContinueFrame(this.id, this.flags, this.checksumType, this.checksum, payload);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -