diff options
Diffstat (limited to 'reactive/kotlinx-coroutines-reactive/test/RangePublisherBufferedTest.kt')
-rw-r--r-- | reactive/kotlinx-coroutines-reactive/test/RangePublisherBufferedTest.kt | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/reactive/kotlinx-coroutines-reactive/test/RangePublisherBufferedTest.kt b/reactive/kotlinx-coroutines-reactive/test/RangePublisherBufferedTest.kt new file mode 100644 index 00000000..b710c590 --- /dev/null +++ b/reactive/kotlinx-coroutines-reactive/test/RangePublisherBufferedTest.kt @@ -0,0 +1,31 @@ +/* + * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license. + */ + +package kotlinx.coroutines.reactive + +import kotlinx.coroutines.flow.* +import org.junit.* +import org.reactivestreams.* +import org.reactivestreams.example.unicast.* +import org.reactivestreams.tck.* + +class RangePublisherBufferedTest : + PublisherVerification<Int>(TestEnvironment(50, 50)) +{ + override fun createPublisher(elements: Long): Publisher<Int> { + return RangePublisher(1, elements.toInt()).asFlow().buffer(2).asPublisher() + } + + override fun createFailedPublisher(): Publisher<Int>? { + return null + } + + @Ignore + override fun required_spec309_requestZeroMustSignalIllegalArgumentException() { + } + + @Ignore + override fun required_spec309_requestNegativeNumberMustSignalIllegalArgumentException() { + } +}
\ No newline at end of file |