@Test
public void disconnectedNodeConnectionTest() {

	RadixNode node = mock(RadixNode.class);
	FindANodeEpic findANodeEpic = new FindANodeEpic(new RandomSelector());
	RadixNodeState nodeState = mock(RadixNodeState.class);
	when(nodeState.getStatus()).thenReturn(WebSocketStatus.DISCONNECTED);
	FindANodeRequestAction request = mock(FindANodeRequestAction.class);
	TestObserver<RadixNodeAction> testObserver = TestObserver.create();
	findANodeEpic.epic(
		Observable.<RadixNodeAction>just(request).concatWith(Observable.never()),
		Observable.just(RadixNetworkState.of(node, nodeState)).concatWith(Observable.never())
	)
	.subscribe(testObserver);
	testObserver.awaitCount(1);
	testObserver.assertValue(u -> u instanceof ConnectWebSocketAction);
	testObserver.assertValue(u -> u.getNode().equals(node));
	testObserver.assertNotComplete();
}