Home
last modified time | relevance | path

Searched refs:createFailedPublisher (Results 1 – 7 of 7) sorted by relevance

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
DRangePublisherTest.kt18 override fun createFailedPublisher(): Publisher<Int>? { in createFailedPublisher() method in kotlinx.coroutines.reactive.RangePublisherTest
37 override fun createFailedPublisher(): Publisher<Int>? { in createFailedPublisher() method in kotlinx.coroutines.reactive.RangePublisherWrappedTwiceTest
DRangePublisherBufferedTest.kt20 override fun createFailedPublisher(): Publisher<Int>? { in createFailedPublisher() method in kotlinx.coroutines.reactive.RangePublisherBufferedTest
DReactiveStreamTckTest.kt34 override fun createFailedPublisher(): Publisher<Long> = in createFailedPublisher() method in kotlinx.coroutines.reactive.ReactiveStreamTckTest.ReactiveStreamTckTestSuite
DUnboundedIntegerIncrementPublisherTest.kt38 override fun createFailedPublisher(): Publisher<Int> { in createFailedPublisher() method in kotlinx.coroutines.reactive.UnboundedIntegerIncrementPublisherTest
DIterableFlowTckTest.kt35 override fun createFailedPublisher(): Publisher<Long>? { in createFailedPublisher() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
DIterableFlowAsFlowableTckTest.kt23 override fun createFailedPublisher(): Publisher<Long>? = null in createFailedPublisher() method in kotlinx.coroutines.rx2.IterableFlowAsFlowableTckTest
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
DIterableFlowAsFlowableTckTest.kt23 override fun createFailedPublisher(): Publisher<Long>? = null in createFailedPublisher() method in kotlinx.coroutines.rx3.IterableFlowAsFlowableTckTest