Presenter for login

LoginPresenter.kt

@AuthScope
class LoginPresenter
@Inject constructor(private val interactor: LoginInteractor) : BasePresenter<LoginState, LoginEvent> {

    private val resultsSubj = PublishSubject.create<LoginResult>().toSerialized()
    private val stateObs: Observable<LoginState>

    init {
        val initial = LoginState()
        stateObs = resultsSubj
                .scan(initial) { old, result -> result.alterState(old) }
                .replay(1)
                .autoConnect()
    }

    override fun state(): Observable<LoginState> {
        return this.stateObs
    }

    override fun attachEvents(events: Observable<LoginEvent>) {
        events.ofType(Submit::class.java)
                .flatMap { event -> interactor.login(event.email, event.password) }
                .subscribe(resultsSubj)
    }
}