PreLollipopNetworkObservingStrategy extends BaseNetworkObservingStrategy { @Override public Observable<RxNetworkInfo> observe() { return Observable.create(new PreLollipopOnSubscribe()).distinctUntilChanged(); } PreLollipopNetworkObservingStrategy(@NonNull Context context); @Override Observable<RxNetworkInfo> observe();  }
@Test public void shouldReceiveCorrectValue_whenConnectivityChanges() { sut.observe().subscribeWith(testObserver); RuntimeEnvironment.application.sendBroadcast(new Intent(CONNECTIVITY_ACTION)); testObserver.assertSubscribed().assertValue(validRxnetworkInfo); }