@Test
public void shouldReceiveCorrectValue_whenConnectivityChanges() {

  sut.observe().subscribeWith(testObserver);
  RuntimeEnvironment.application.sendBroadcast(new Intent(CONNECTIVITY_ACTION));
  testObserver.assertSubscribed().assertValue(validRxnetworkInfo);
}