@Test
public void testBadHealthDownstreamSourceTerminatesClientSubscription() {

    StepVerifier.create(healthService.events(false))
            // Break downstream health provider
            .then(() -> {
                downstream2.breakSubscriptionsWithError(new RuntimeException("Simulated error"));
            })
            .verifyError(RuntimeException.class);
}