assertExecutor() — netty Function Reference

Architecture documentation for the assertExecutor() function in DefaultChannelPipelineTest.java from the netty codebase.

Function java Buffer Telemetry called by 2

Entity Profile

Buffer→ Telemetry→ assertExecutor() — netty Function Reference

Dependency Diagram

graph TD
  151488c4_dff5_3770_3c96_c60f435e4ade["assertExecutor()"]
  a3de3ac1_8b11_1455_2fb4_1f6fbefec5d0["CheckEventExecutorHandler"]
  151488c4_dff5_3770_3c96_c60f435e4ade -->|defined in| a3de3ac1_8b11_1455_2fb4_1f6fbefec5d0
  79ac8b37_cf44_c6e9_313d_67392c43757c["handlerAdded()"]
  79ac8b37_cf44_c6e9_313d_67392c43757c -->|calls| 151488c4_dff5_3770_3c96_c60f435e4ade
  28107c94_db85_380b_dc39_f590c93690f2["handlerRemoved()"]
  28107c94_db85_380b_dc39_f590c93690f2 -->|calls| 151488c4_dff5_3770_3c96_c60f435e4ade
  style 151488c4_dff5_3770_3c96_c60f435e4ade fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java lines 2376–2389

        private void assertExecutor(ChannelHandlerContext ctx, Promise<Void> promise) {
            final boolean same;
            try {
                same = executor == ctx.executor();
            } catch (Throwable cause) {
                promise.setFailure(cause);
                return;
            }
            if (same) {
                promise.setSuccess(null);
            } else {
                promise.setFailure(new AssertionError("EventExecutor not the same"));
            }
        }