@Test
public void testBadSubscriberIsIsolated() {

    // First event / one subscriber
    TitusRxSubscriber<ContainerHealthEvent> goodSubscriber = new TitusRxSubscriber<>();
    healthService.events(false).subscribe(goodSubscriber);
    // Add bad subscriber
    Disposable badSubscriber = healthService.events(false).subscribe(
            next -> {
                throw new RuntimeException("simulated error");
            },
            e -> {
                throw new RuntimeException("simulated error");
            },
            () -> {
                throw new RuntimeException("simulated error");
            }
    );
    downstream1.makeHealthy(taskId1);
    assertThat(goodSubscriber.isOpen()).isTrue();
    assertThat(badSubscriber.isDisposed()).isTrue();
}