1 package kotlinx.coroutines.rx3 2 3 import io.reactivex.rxjava3.core.* 4 import kotlinx.coroutines.flow.* 5 import org.junit.* 6 import org.reactivestreams.* 7 import org.reactivestreams.tck.* 8 9 class IterableFlowAsFlowableTckTest : PublisherVerification<Long>(TestEnvironment()) { 10 generatenull11 private fun generate(num: Long): Array<Long> { 12 return Array(if (num >= Integer.MAX_VALUE) 1000000 else num.toInt()) { it.toLong() } 13 } 14 createPublishernull15 override fun createPublisher(elements: Long): Flowable<Long> { 16 return generate(elements).asIterable().asFlow().asFlowable() 17 } 18 createFailedPublishernull19 override fun createFailedPublisher(): Publisher<Long>? = null 20 21 @Ignore 22 override fun required_spec309_requestZeroMustSignalIllegalArgumentException() { 23 } 24 25 @Ignore required_spec309_requestNegativeNumberMustSignalIllegalArgumentExceptionnull26 override fun required_spec309_requestNegativeNumberMustSignalIllegalArgumentException() { 27 } 28 29 @Ignore required_spec312_cancelMustMakeThePublisherToEventuallyStopSignalingnull30 override fun required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling() { 31 // 32 } 33 } 34