@Test(timeout = 5_000)
public void testQueueingTimeOut() {

    List<String> result = new CopyOnWriteArrayList<>();
    AtomicReference<Throwable> errorRef = new AtomicReference<>();
    reactorSerializedInvoker.submit(Mono.delay(Duration.ofHours(1)).timeout(QUEUEING_TIMEOUT).map(tick -> "First")).subscribe(
            result::add,
            errorRef::set
    );
    reactorSerializedInvoker.submit(Mono.just("Second")).subscribe(result::add, errorRef::set);
    await().until(() -> result.size() == 1 && errorRef.get() != null);
    assertThat(result.get(0)).isEqualTo("Second");
}