@Test
public void shouldBuildReactiveStreamForValidNetworkAddress() throws Exception {

  NetworkAddress networkAddress = NetworkAddress.builder()
      .ip("192.168.1.44")
      .port(9998)
      .build();
  SearchServerInteractor.Params params =
      SearchServerInteractor.Params.forNetworkAddress(networkAddress);
  when(mockNetworkAddressValidator.isValid(networkAddress)).thenReturn(true);
  searchServerInteractor.buildReactiveStream(params);
  verify(searchServerService, times(1)).searchServer(networkAddress);
  verifyNoMoreInteractions(searchServerService);
}