@Test
public void testValidClient() {

	RadixNode node = mock(RadixNode.class);
	WebSocketClient ws = mock(WebSocketClient.class);
	when(ws.sendMessage(any())).thenReturn(true);
	FindANodeRequestAction request = mock(FindANodeRequestAction.class);
	FindANodeEpic findANodeFunction = new FindANodeEpic(new GetFirstSelector());
	TestObserver<RadixNodeAction> testObserver = TestObserver.create();
	findANodeFunction.epic(
		Observable.<RadixNodeAction>just(request).concatWith(Observable.never()),
		Observable.just(RadixNetworkState.of(node, mockedNodeState(WebSocketStatus.CONNECTED)))
	)
	.subscribe(testObserver);
	testObserver.awaitCount(1);
	testObserver.assertValue(u -> u.getNode().equals(node));
}