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

    AtomicReference<Object> resultRef = new AtomicReference<>();
    Disposable disposable = reactorSerializedInvoker.submit(Mono.delay(Duration.ofHours(1)).map(tick -> "First")).subscribe(
            resultRef::set,
            resultRef::set
    );
    await().until(disposable::isDisposed);
    assertThat(resultRef.get()).isInstanceOf(TimeoutException.class);
}