netty Architecture Docs
Home / Function/ testFailedFutureFailPending() — netty Function Reference

testFailedFutureFailPending() — netty Function Reference

Architecture documentation for the testFailedFutureFailPending() function in PromiseAggregatorTest.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Dependency Diagram

graph TD
  772deb78_d776_419c_3de9_65e04a4d0084["testFailedFutureFailPending()"]
  b88589a3_9d2d_214c_ca51_54d5a42e4fe6["PromiseAggregatorTest"]
  772deb78_d776_419c_3de9_65e04a4d0084 -->|defined in| b88589a3_9d2d_214c_ca51_54d5a42e4fe6
  style 772deb78_d776_419c_3de9_65e04a4d0084 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

common/src/test/java/io/netty/util/concurrent/PromiseAggregatorTest.java lines 97–122

    @SuppressWarnings("unchecked")
    @Test
    public void testFailedFutureFailPending() throws Exception {
        Promise<Void> p = mock(Promise.class);
        PromiseAggregator<Void, Future<Void>> a =
                new PromiseAggregator<Void, Future<Void>>(p);
        Promise<Void> p1 = mock(Promise.class);
        Promise<Void> p2 = mock(Promise.class);
        Throwable t = mock(Throwable.class);

        when(p1.addListener(a)).thenReturn(p1);
        when(p2.addListener(a)).thenReturn(p2);
        when(p1.isSuccess()).thenReturn(false);
        when(p1.cause()).thenReturn(t);
        when(p.setFailure(t)).thenReturn(p);
        when(p2.setFailure(t)).thenReturn(p2);

        a.add(p1, p2);
        a.operationComplete(p1);

        verify(p1).addListener(a);
        verify(p2).addListener(a);
        verify(p1).cause();
        verify(p).setFailure(t);
        verify(p2).setFailure(t);
    }

Domain

Subdomains

Defined In

Source

Frequently Asked Questions

What does testFailedFutureFailPending() do?
testFailedFutureFailPending() is a function in the netty codebase, defined in common/src/test/java/io/netty/util/concurrent/PromiseAggregatorTest.java.
Where is testFailedFutureFailPending() defined?
testFailedFutureFailPending() is defined in common/src/test/java/io/netty/util/concurrent/PromiseAggregatorTest.java at line 97.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free