@Test
public void multicastSelectorCallableConnectableCrash() {

    FlowableReplay.multicastSelector(new Callable<ConnectableFlowable<Object>>() {
        @Override
        public ConnectableFlowable<Object> call() throws Exception {
            throw new TestException();
        }
    }, Functions.<Flowable<Object>>identity())
    .test()
    .assertFailure(TestException.class);
}