newChannelAsync() — netty Function Reference

Architecture documentation for the newChannelAsync() function in UniqueIpFilterTest.java from the netty codebase.

Function java Buffer Allocators called by 1

Entity Profile

Buffer→ Allocators→ newChannelAsync() — netty Function Reference

Dependency Diagram

graph TD
  4f676050_4c24_f361_f493_0a591cde99bc["newChannelAsync()"]
  a74d4a73_e4e4_9c5c_930d_7d3ee65c7137["UniqueIpFilterTest"]
  4f676050_4c24_f361_f493_0a591cde99bc -->|defined in| a74d4a73_e4e4_9c5c_930d_7d3ee65c7137
  036e83aa_d0d3_f2bf_0be2_4f2510191b24["testUniqueIpFilterHandler()"]
  036e83aa_d0d3_f2bf_0be2_4f2510191b24 -->|calls| 4f676050_4c24_f361_f493_0a591cde99bc
  style 4f676050_4c24_f361_f493_0a591cde99bc fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/ipfilter/UniqueIpFilterTest.java lines 59–74

    private static Future<EmbeddedChannel> newChannelAsync(final CyclicBarrier barrier,
            ExecutorService executorService,
            final ChannelHandler... handler) {
        return executorService.submit(new Callable<EmbeddedChannel>() {
            @Override
            public EmbeddedChannel call() throws Exception {
                barrier.await();
                return new EmbeddedChannel(handler) {
                    @Override
                    protected SocketAddress remoteAddress0() {
                        return isActive() ? SocketUtils.socketAddress("91.92.93.1", 5421) : null;
                    }
                };
            }
        });
    }