@Test(timeout = 30_000)
public void testAggregation() {

    Iterator<ReadinessStatus> it = resolver.observeLocalMasterReadinessUpdates().toIterable().iterator();
    // Enabled + Disabled == Disabled
    delegate1Processor.onNext(newStatus(ReadinessState.Enabled));
    delegate2Processor.onNext(newStatus(ReadinessState.Disabled));
    Assertions.assertThat(it.next().getState()).isEqualTo(ReadinessState.Disabled);
    // Enabled + Enabled == Enabled
    delegate2Processor.onNext(newStatus(ReadinessState.Enabled));
    Assertions.assertThat(it.next().getState()).isEqualTo(ReadinessState.Enabled);
    // Disabled + Enabled == Disabled
    delegate1Processor.onNext(newStatus(ReadinessState.Disabled));
    Assertions.assertThat(it.next().getState()).isEqualTo(ReadinessState.Disabled);
}