I would do it somewhatr like this: ``` Observable...

# rx

[tschuchort]

I would do it somewhatr like this:

Observable.just(Unit)
    .subscribeOn(<http://Schedulers.io|Schedulers.io>())
    .map { conn.connect() }
    .observeOn(Schedulers.mainThread())
    .subscribe { 
        showCertDetails(it)
    }, { error ->
       showError(error)
    }