unit-testing - Project Reactor: ブロードキャスターが終了するまで待ちます

Question

文字列を受け取り、それらを StringBuilder に追加する Broadcaster があります。

テストしたいです。

Thread#sleepブロードキャスターが文字列の処理を終えるまで、私は待たなければなりません。削除したいsleep。

使ってみてControl#debug()失敗。

public class BroadcasterUnitTest {

@Test
public void test() {
    //prepare
    Environment.initialize();
    Broadcaster<String> sink = Broadcaster.create(Environment.newDispatcher()); //run broadcaster in separate thread (dispatcher)
    StringBuilder sb = new StringBuilder();
    sink
            .observe(s -> sleep(100)) //long-time operation
            .consume(sb::append);

    //do
    sink.onNext("a");
    sink.onNext("b");

    //assert
    sleep(500);//wait while broadcaster finished (if comment this line then the test will fail)
    assertEquals("ab", sb.toString());
}

private void sleep(int millis) {
    try {
        Thread.sleep(millis);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
}
}