write() — netty Function Reference

Architecture documentation for the write() function in RedisClientHandler.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ write() — netty Function Reference

Dependency Diagram

graph TD
  a98043b1_fd24_af56_ffcc_b7d491b322b4["write()"]
  0da4c5dd_81b9_9df4_f97a_3de1b5c89a03["RedisClientHandler"]
  a98043b1_fd24_af56_ffcc_b7d491b322b4 -->|defined in| 0da4c5dd_81b9_9df4_f97a_3de1b5c89a03
  style a98043b1_fd24_af56_ffcc_b7d491b322b4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

example/src/main/java/io/netty/example/redis/RedisClientHandler.java lines 41–50

    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
        String[] commands = ((String) msg).split("\\s+");
        List<RedisMessage> children = new ArrayList<RedisMessage>(commands.length);
        for (String cmdString : commands) {
            children.add(new FullBulkStringRedisMessage(ByteBufUtil.writeUtf8(ctx.alloc(), cmdString)));
        }
        RedisMessage request = new ArrayRedisMessage(children);
        ctx.write(request, promise);
    }