@Override
    protected void initChannel(final SocketChannel channel) {
        channel.pipeline().addLast(new ProtobufVarint32FrameDecoder());
        channel.pipeline().addLast(new ProtobufDecoder(CDCRequest.getDefaultInstance()));
        channel.pipeline().addLast(new ProtobufVarint32LengthFieldPrepender());
        channel.pipeline().addLast(new ProtobufEncoder());
        channel.pipeline().addLast(new CDCChannelInboundHandler());
    }
@Test
    void assertInitChannel() {
        SocketChannel channel = mock(SocketChannel.class);
        ChannelPipeline pipeline = mock(ChannelPipeline.class);
        when(channel.pipeline()).thenReturn(pipeline);
        CDCServerHandlerInitializer initializer = new CDCServerHandlerInitializer();
        initializer.initChannel(channel);
        verify(pipeline).addLast(any(ProtobufVarint32FrameDecoder.class));
        verify(pipeline).addLast(any(ProtobufDecoder.class));
        verify(pipeline).addLast(any(ProtobufVarint32LengthFieldPrepender.class));
        verify(pipeline).addLast(any(ProtobufEncoder.class));
        verify(pipeline).addLast(any(CDCChannelInboundHandler.class));
    }