PromiseCombinerTest Class — netty Architecture

Source Code

common/src/test/java/io/netty/util/concurrent/PromiseCombinerTest.java lines 36–267

public class PromiseCombinerTest {
    @Mock
    private Promise<Void> p1;
    private GenericFutureListener<Future<Void>> l1;
    private final GenericFutureListenerConsumer l1Consumer = new GenericFutureListenerConsumer() {
        @Override
        public void accept(GenericFutureListener<Future<Void>> listener) {
            l1 = listener;
        }
    };
    @Mock
    private Promise<Void> p2;
    private GenericFutureListener<Future<Void>> l2;
    private final GenericFutureListenerConsumer l2Consumer = new GenericFutureListenerConsumer() {
        @Override
        public void accept(GenericFutureListener<Future<Void>> listener) {
            l2 = listener;
        }
    };
    @Mock
    private Promise<Void> p3;
    private PromiseCombiner combiner;

    @BeforeEach
    public void setup() {
        MockitoAnnotations.initMocks(this);
        combiner = new PromiseCombiner(ImmediateEventExecutor.INSTANCE);
    }

    @Test
    public void testNullArgument() {
        try {
            combiner.finish(null);
            fail();
        } catch (NullPointerException expected) {
            // expected
        }
        combiner.finish(p1);
        verify(p1).trySuccess(null);
    }

    @Test
    public void testNullAggregatePromise() {
        combiner.finish(p1);
        verify(p1).trySuccess(null);
    }

    @Test
    public void testAddNullPromise() {
        assertThrows(NullPointerException.class, new Executable() {
            @Override
            public void execute() {
                combiner.add(null);
            }
        });
    }

    @Test
    public void testAddAllNullPromise() {
        assertThrows(NullPointerException.class, new Executable() {
            @Override
            public void execute() {
                combiner.addAll(null);
            }
        });
    }

    @Test
    public void testAddAfterFinish() {
        combiner.finish(p1);
        assertThrows(IllegalStateException.class, new Executable() {
            @Override
            public void execute() {
                combiner.add(p2);
            }
        });
    }

    @SuppressWarnings("unchecked")
    @Test
    public void testAddAllAfterFinish() {