testExceptionIsPropagatedToTerminationFuture() — netty Function Reference

Source Code

common/src/test/java/io/netty/util/concurrent/SingleThreadEventExecutorTest.java lines 638–661

    @Test
    @Timeout(value = 5000, unit = TimeUnit.MILLISECONDS)
    public void testExceptionIsPropagatedToTerminationFuture() throws Exception {
        final IllegalStateException exception = new IllegalStateException();
        final SingleThreadEventExecutor executor =
                new SingleThreadEventExecutor(null, Executors.defaultThreadFactory(), true) {
                    @Override
                    protected void run() {
                        throw exception;
                    }
                };

        // Schedule something so we are sure the run() method will be called.
        executor.execute(new Runnable() {
            @Override
            public void run() {
                // Noop.
            }
        });

        executor.terminationFuture().await();

        assertSame(exception, executor.terminationFuture().cause());
    }