RxJava подписывается и наблюдает за тем же потоком, что и модульный тест

Я хочу написать своего рода «тест черного ящика» для компонента, который внутренне использует RxJava.

Внутри он использует Retrofit, который возвращает Observable для выполнения HTTP-вызова, а затем использует .flatmap() для будущей обработки данных, полученных при модернизации. Идея состоит в том, чтобы дать этому компоненту Transformer для установки планировщиков в наблюдателе следующим образом:

class DefaultTransformer <T> implements Transformer<T, T> {

   public Observable<T> call(Observable<T> observable) { 
      return observable.subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread());
   }
}

Мой компонент делает что-то вроде этого:

void execute(Transformer<T, T> scheduler){
     Observable<List<Team>> observable = retrofitApi.getLeague(leagueId, seasonId)
        .flatMap(new Func1<LeagueWrapper, Observable<List<Team>>>() {
          @Override public Observable<List<Team>> call(LeagueWrapper wrapper) {                
             return Observable.just(wrapper.getLeague().getTeams());
          }
        });

   observable.compose(transformer);

   observable.subscribe(this);
}

В рабочей среде я передаю DefaultTransformer в качестве параметра, но для модульных тестов я хочу отправить Transformer, который выполняется в том же потоке, что и модульный тест, поэтому все должно выполняться синхронно (а не асинхронно).

Я пробовал это:

class UnitTestTransformer <T> implements Transformer<T, T> {

       public Observable<T> call(Observable<T> observable) { 
          return observable.subscribeOn(Schedulers.test()).observeOn(AndroidSchedulers.test());
       }
    }

Но он по-прежнему работает асинхронно в моих модульных тестах. Я также пробовал Scheduler.immediate(). toBlocking() похоже не вариант, потому что это уже не Observable. Есть идеи, что может быть не так?