| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherAsFlowTest.kt | 19 val publisher = flowPublish(currentDispatcher()) { in <lambda>()
47 val publisher = flowPublish(currentDispatcher()) { in <lambda>()
68 val publisher = flowPublish(currentDispatcher()) { in <lambda>()
85 val publisher = flowPublish(currentDispatcher()) { in <lambda>()
104 val publisher = flowPublish(currentDispatcher()) { in <lambda>()
125 val publisher = flowPublish(currentDispatcher()) { in <lambda>()
134 val flow = flowPublish(currentDispatcher()) { repeat(10) { send(it) } }.asFlow() in <lambda>()
151 val flow = flowPublish(currentDispatcher()) { in <lambda>()
|
| D | PublishTest.kt | 16 val publisher = flowPublish<Int>(currentDispatcher()) { in <lambda>()
34 val publisher = flowPublish(currentDispatcher()) { in <lambda>()
60 val publisher = flowPublish<Int>(currentDispatcher()) { in <lambda>()
127 val publisher = flowPublish(currentDispatcher()) { in <lambda>()
166 val pub = flowPublish(currentDispatcher()) { in <lambda>()
|
| D | PublisherBackpressureTest.kt | 15 val observable = flowPublish(currentDispatcher()) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | CompletableTest.kt | 18 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
33 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
53 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
76 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
87 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
103 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
129 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
|
| D | FlowableTest.kt | 16 val observable = rxFlowable(currentDispatcher()) { in <lambda>()
33 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>()
53 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>()
76 rxFlowable(currentDispatcher()) { in <lambda>()
112 val pub = rxFlowable(currentDispatcher()) { in <lambda>()
|
| D | ObservableTest.kt | 25 val observable = rxObservable(currentDispatcher()) { in <lambda>()
42 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>()
62 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>()
85 rxObservable(currentDispatcher()) { in <lambda>()
122 val pub = rxObservable(currentDispatcher()) { in <lambda>()
|
| D | MaybeTest.kt | 28 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
45 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
61 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
82 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
208 val maybe = rxMaybe<Int>(currentDispatcher()) { in <lambda>()
233 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
259 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
|
| D | SingleTest.kt | 26 val single = rxSingle(currentDispatcher()) { in <lambda>()
43 val single = rxSingle(currentDispatcher()) { in <lambda>()
64 val single = rxSingle(currentDispatcher()) { in <lambda>()
185 val single = rxSingle(currentDispatcher()) { in <lambda>()
237 val single = rxSingle(currentDispatcher()) { in <lambda>()
|
| D | ObservableAsFlowTest.kt | 24 val source = rxObservable(currentDispatcher()) { in testCancellation()
140 val source = rxObservable(currentDispatcher()) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | CompletableTest.kt | 18 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
33 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
53 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
76 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
87 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
103 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
129 val completable = rxCompletable(currentDispatcher()) { in <lambda>()
|
| D | FlowableTest.kt | 17 val observable = rxFlowable(currentDispatcher()) { in <lambda>()
34 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>()
54 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>()
77 rxFlowable(currentDispatcher()) { in <lambda>()
113 val pub = rxFlowable(currentDispatcher()) { in <lambda>()
|
| D | ObservableTest.kt | 25 val observable = rxObservable(currentDispatcher()) { in <lambda>()
42 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>()
62 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>()
85 rxObservable(currentDispatcher()) { in <lambda>()
122 val pub = rxObservable(currentDispatcher()) { in <lambda>()
|
| D | MaybeTest.kt | 28 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
45 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
61 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
82 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
208 val maybe = rxMaybe<Int>(currentDispatcher()) { in <lambda>()
233 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
259 val maybe = rxMaybe(currentDispatcher()) { in <lambda>()
|
| D | SingleTest.kt | 26 val single = rxSingle(currentDispatcher()) { in <lambda>()
43 val single = rxSingle(currentDispatcher()) { in <lambda>()
64 val single = rxSingle(currentDispatcher()) { in <lambda>()
185 val single = rxSingle(currentDispatcher()) { in <lambda>()
237 val single = rxSingle(currentDispatcher()) { in <lambda>()
|
| D | ObservableAsFlowTest.kt | 24 val source = rxObservable(currentDispatcher()) { in testCancellation()
140 val source = rxObservable(currentDispatcher()) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherAsFlowTest.kt | 20 val publisher = publish(currentDispatcher()) { in <lambda>()
48 val publisher = publish(currentDispatcher()) { in <lambda>()
69 val publisher = publish(currentDispatcher()) { in <lambda>()
86 val publisher = publish(currentDispatcher()) { in <lambda>()
105 val publisher = publish(currentDispatcher()) { in <lambda>()
126 val publisher = publish(currentDispatcher()) { in <lambda>()
135 val flow = publish(currentDispatcher()) { repeat(10) { send(it) } }.asFlow() in <lambda>()
152 val flow = publish(currentDispatcher()) { in <lambda>()
|
| D | PublishTest.kt | 16 val publisher = publish<Int>(currentDispatcher()) { in <lambda>()
34 val publisher = publish(currentDispatcher()) { in <lambda>()
60 val publisher = publish<Int>(currentDispatcher()) { in <lambda>()
127 val publisher = publish(currentDispatcher()) { in <lambda>()
166 val pub = publish(currentDispatcher()) { in <lambda>()
|
| D | PublisherBackpressureTest.kt | 15 val observable = publish(currentDispatcher()) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FluxTest.kt | 18 val flux = flux(currentDispatcher()) { in <lambda>()
35 val flux = flux<String>(currentDispatcher()) { in <lambda>()
55 val flux = flux<String>(currentDispatcher()) { in <lambda>()
78 flux(currentDispatcher()) { in <lambda>()
114 val pub = flux(currentDispatcher()) { in <lambda>()
|
| D | MonoTest.kt | 29 val mono = mono(currentDispatcher()) { in <lambda>()
46 val mono = mono(currentDispatcher()) { in <lambda>()
66 val mono = mono(currentDispatcher()) { in <lambda>()
82 val mono = mono(currentDispatcher()) { in <lambda>()
202 val mono = mono(currentDispatcher()) { in <lambda>()
230 val mono = mono(currentDispatcher()) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | TestBase.kt | 224 protected suspend fun currentDispatcher() = coroutineContext[ContinuationInterceptor]!! in <lambda>() method in kotlinx.coroutines.TestBase
|