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

# rx

[oday]

fun findCurrentUser(email: String): Disposable =
        Single.fromCallable {
            database.userDao()
                .findByEmail("sdpaksdasd")
        }
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe({ result ->
                Timber.d("No error")
            }, { error: Throwable ->
                Timber.d("Error here")
            })