yusukezzz

// RetryWithDelay 使用例
fun main(args: Array<String>) {
    Observable.create<String> { subscriber ->
        subscriber.onNext("test")
        subscriber.onError(Throwable("error occurred"))
    }
    .retryWhen(RetryWithDelay(3, 1000L))
    // toBlocking() や Thread.sleep() 的なものがないとメインスレッドが一瞬で終了してリトライ中の処理ごと死んでしまう
    // 実処理では blocking するわけに行かないので処理中に死んだ場合を考慮する必要があるかも
    //   -> Android なら onStop() での unsubscribe() ? 要調査