@Test
public void applyWithProgressingAsTrueThenDoNotUpdateCitiesCount() {

    BehaviorSubject<Boolean> progressing = BehaviorSubject.createDefault(true);
    BehaviorSubject<Integer> citiesCount = BehaviorSubject.create();
    new CountCitiesInteractor(progressing, citiesCount).apply(Flowable.just(10));
    assertTrue(citiesCount.getValue() == null);
}