RxKotlin

Tweet

SingleOnSubscribeのサンプル

import io.reactivex.Single
import io.reactivex.SingleEmitter
import io.reactivex.SingleObserver
import io.reactivex.SingleOnSubscribe
import io.reactivex.disposables.Disposable
import io.reactivex.schedulers.Schedulers

class mySubscriber: SingleOnSubscribe<String> {
    override fun subscribe(emitter: SingleEmitter<String>) {
        println("実行します")
        Thread.sleep(1*1000)
        println("実行が終わりました")
        emitter.onSuccess("onSuccessで呼び出します")
    }
}

class myObserver: SingleObserver<String> {
    override fun onSuccess(t: String) {
        //TODO("Not yet implemented")
        println(t)
    }

    override fun onSubscribe(d: Disposable) {
        //TODO("Not yet implemented")
    }

    override fun onError(e: Throwable) {
        //TODO("Not yet implemented")
    }

}
fun main(args:Array<String>) {
    val sub = mySubscriber()
    val obs = myObserver()

    val single = Single.create<String>(sub)
    single.observeOn(Schedulers.computation())
            .subscribe(obs)
    Thread.sleep(10*1000)
}

どうも、チェインでソースを書くと汚いから、やっぱりちゃんと継承して書いたほうがいいな。