``` fun findCurrentUser(email: String): Dispos...

# android

[oday]

fun findCurrentUser(email: String): Disposable =
        database.userDao().findByEmail("this must fail")
            .subscribeOn(<http://Schedulers.io|Schedulers.io>())
            .observeOn(
                AndroidSchedulers.mainThread()
            ).subscribe({ result ->

            Timber.d("no error")
        }, { error ->
            Timber.d("Error here")
        })