FrangSierra

@get:Rule
val cleanState = cleanStateRule()

@Test
fun login_redirects_to_home_with_success_task() {
     //Set login state to success
     onUiSync {
         val loggedUser = User(email = MockModels.anyEmail, uid = MockModels.anyId, username = MockModels.anyUsername, photoUrl = MockModels.anyPhoto)
         val state = SessionState().copy(loginRequestState = requestSuccess(), verified = false, loggedIn = true, loggedUser = loggedUser)
         sessionStore.setTestState(state)

FrangSierra

@get:Rule
val testDispatcher = testDispatcherRule()

@Test
fun login_button_dispatch_login_action() {
    onView(withId(R.id.username_edit_text)).perform(typeText("someUsername"))
    onView(withId(R.id.password_edit_text)).perform(typeText("somePassword"))
    onView(withId(R.id.login_button)).perform(click())
    
    assertThat(testDispatcher.actions, contains(LoginAction(someUsername, somePassword)))

FrangSierra

  
fun listenUsernameChanges(){
   //Using RxJava  
        sessionStore
                .flowable()
                .map { it.name }
                .subscribe { updateUsername(it) }
          
  // Custom callback      
        sessionStore

FrangSierra

data class SessionState(val loginTask : Task = taskIdle(),
                        val loggedUsername : String? = null)
                        

class SessionStore : Store<SessionState>(val loginController : controller) {

    @Reducer
    fun login(action: LoginAction): SessionState {
        controller.login(user = action.username, password = action.password)
        return state.copy(loginTask = taskRunning())

FrangSierra

data class LoginAction(val username: String, val password: String) : Action
data class LoginCompleteAction(val loginTask: Task, val user: User?)