@Test
public void replaySelectorConnectableReturnsNull() {

    ObservableReplay.multicastSelector(Functions.justCallable((ConnectableObservable<Integer>)null), Functions.justFunction(Observable.just(1)))
    .test()
    .assertFailureAndMessage(NullPointerException.class, "The connectableFactory returned a null ConnectableObservable");
}