rxjava-backpressure-drop-example3.kt

        Observable.interval(1, TimeUnit.MICROSECONDS)
            .toFlowable(BackpressureStrategy.DROP)
            .observeOn(Schedulers.io(), false, 1)
            .doOnNext { t ->
                println(t)

                try {
                    Thread.sleep(1000)
                } catch (e: Exception) {
                    //
                }
            }
            .subscribe(Consumer { myLong ->
                // equals to onNext
            }, Consumer { myThrowable ->
                // equals to onError
            }, Action {
                // equals to onComplete
            })