    @Test
    public void testAwaitComplete() throws Exception {


        observerAC.getValue().onComplete();

        assertTimeout(Duration.ofMillis(1000), () -> {
            // needs to return immediately
            uut.awaitComplete();
        });
    }