### Question:
GetReposUseCase extends BaseUseCase { public Flowable<List<Repos>> get(ReposParam param) { return reposRepository .all(param) .subscribeOn(executionThread) .observeOn(postExecutionThread); } @Inject  GetReposUseCase(ReposRepository userRepository, PostExecutorThread postExecutionThread); Flowable<List<Repos>> get(ReposParam param);  }### Answer:
@Test public void testPositiveOnValidData() { ReposParam param = new ReposParam("testName"); List<Repos> listData = new ArrayList<>(); listData.add(new Repos("1", "repos test name", "repos test full name")); listData.add(new Repos("2", "repos test name 2", "repos test full name 2")); when(reposRepository.all(param)).thenReturn(Flowable.just(listData)); TestSubscriber<List<Repos>> subscriber = new TestSubscriber<>(); reposUseCase .get(param) .subscribe(subscriber); testScheduler.triggerActions(); subscriber.assertValueCount(1); subscriber.assertSubscribed(); subscriber.assertValue(listData); subscriber.dispose(); }