Как передать FluxSink обработчику Netty?

Question

Я пытаюсь передать данные из Netty в WebFlux. Я просто пытаюсь понять, как передать FluxSink<DataBuffer> в конвейер, чтобы я мог поместить в него данные.

    this.ctx = ctx;
    buffer = ctx.alloc().buffer();
    ctx.pipeline()
        .addLast(new SimpleChannelInboundHandler<HttpContent>() {

            @Override
            public void channelRead0(final ChannelHandlerContext ctx, final HttpContent content) throws Exception {

                content.replace(buffer);
//              sink.next(new DefaultDataBufferFactory().wrap(buffer.nioBuffer()));
                if (content instanceof LastHttpContent) {
//                  sink.complete();
                }
                System.out.println(content.content().toString(StandardCharsets.UTF_8));
            }
        });