@Test
public void testFailingEmitter() throws Exception {

    ObservableExt.periodicGenerator(
            BAD_SOURCE, INITIAL_DELAY_MS, INTERVAL_MS, TimeUnit.MILLISECONDS, testScheduler
    ).subscribe(testSubscriber);
    // Check emits
    expectBadEmit(INITIAL_DELAY_MS);
}