SignOut { public Observable<Void> execute() { return mRepository.query(new SessionQuery.SignOut()); } SignOut(Repository<? extends User> repository); Observable<Void> execute();  }
@Test public void whenMessagesForChatRequested_thenRepoIsQueriedForCorrectChatId() throws Exception { when(mMockRepository.query(eq(new SessionQuery.SignOut()))) .thenReturn(Observable.empty()); mTarget.execute(); verify(mMockRepository, times(1)).query(eq(new SessionQuery.SignOut())); }