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);
}
}