add func
This commit is contained in:
@@ -37,7 +37,6 @@ class RxJavaBackPressureTest {
|
||||
@Test
|
||||
fun testIntervalBackPressure() = runBlocking(Dispatchers.Default) {
|
||||
val subscription = Flowable.interval(50, MILLISECONDS).doOnNext {
|
||||
Log.d("RxJava2", "-- do action --")
|
||||
}.subscribeOn(Schedulers.computation()).observeOn(Schedulers.io()).subscribe {
|
||||
Thread.sleep(2000)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user