connect() — netty Function Reference

Architecture documentation for the connect() function in CombinedChannelDuplexHandlerTest.java from the netty codebase.

Function java Buffer Telemetry called by 2

Entity Profile

Buffer→ Telemetry→ connect() — netty Function Reference

Dependency Diagram

graph TD
  9524403e_b4a7_5578_74ea_1eb43c3b6262["connect()"]
  22b98a35_48d2_27a4_b6c2_3b5211afeaa9["OutboundEventHandler"]
  9524403e_b4a7_5578_74ea_1eb43c3b6262 -->|defined in| 22b98a35_48d2_27a4_b6c2_3b5211afeaa9
  fea48d8b_c02b_5b24_c3d4_4003a2c24e9d["doOutboundOperations()"]
  fea48d8b_c02b_5b24_c3d4_4003a2c24e9d -->|calls| 9524403e_b4a7_5578_74ea_1eb43c3b6262
  e5446515_c21b_50da_6c58_52140ea78ad4["testPromisesPassed()"]
  e5446515_c21b_50da_6c58_52140ea78ad4 -->|calls| 9524403e_b4a7_5578_74ea_1eb43c3b6262
  style 9524403e_b4a7_5578_74ea_1eb43c3b6262 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/CombinedChannelDuplexHandlerTest.java lines 421–432

        @Override
        public void connect(ChannelHandlerContext ctx, SocketAddress remoteAddress,
                            SocketAddress localAddress, ChannelPromise promise) {
            try {
                assertSame(REMOTE_ADDRESS, remoteAddress);
                assertSame(LOCAL_ADDRESS, localAddress);
                queue.add(Event.CONNECT);
                promise.setSuccess();
            } catch (AssertionError e) {
                promise.setFailure(e);
            }
        }