public void write()

in runner-core/src/main/java/org/apache/apisix/plugin/runner/handler/PayloadEncoder.java [31:38]


    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        if (msg instanceof A6Response) {
            A6Response response = (A6Response) msg;
            ByteBuffer buffer = encode(response);
            ByteBuf buf = Unpooled.wrappedBuffer(buffer);
            ctx.write(buf, promise);
        }
    }