@Test
public void when_seeds_return_an_error__epic_should_not_fail() {

	Observable<RadixNode> seeds = Observable.error(new RuntimeException("BAD EXCEPTION!"));
	RadixUniverseConfig universe = mock(RadixUniverseConfig.class);
	DiscoverNodesEpic discoverNodesEpic = new DiscoverNodesEpic(seeds, universe);
	ReplaySubject<RadixNodeAction> actions = ReplaySubject.create();
	Observable<RadixNetworkState> networkState = Observable.just(mock(RadixNetworkState.class));
	Observable<RadixNodeAction> output = discoverNodesEpic.epic(actions, networkState);
	TestObserver<RadixNodeAction> testObserver = TestObserver.create();
	output.subscribe(testObserver);
	actions.onNext(DiscoverMoreNodesAction.instance());
	testObserver.assertNoErrors();
	testObserver.awaitCount(1);
	testObserver.assertValue(a -> a instanceof DiscoverMoreNodesErrorAction);
}