1 /* 2 * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license. 3 */ 4 5 package kotlinx.coroutines.reactive 6 7 import kotlinx.coroutines.flow.* 8 import org.junit.* 9 import org.reactivestreams.* 10 import org.reactivestreams.example.unicast.* 11 import org.reactivestreams.tck.* 12 13 class RangePublisherBufferedTest : 14 PublisherVerification<Int>(TestEnvironment(50, 50)) 15 { createPublishernull16 override fun createPublisher(elements: Long): Publisher<Int> { 17 return RangePublisher(1, elements.toInt()).asFlow().buffer(2).asPublisher() 18 } 19 createFailedPublishernull20 override fun createFailedPublisher(): Publisher<Int>? { 21 return null 22 } 23 24 @Ignore required_spec309_requestZeroMustSignalIllegalArgumentExceptionnull25 override fun required_spec309_requestZeroMustSignalIllegalArgumentException() { 26 } 27 28 @Ignore required_spec309_requestNegativeNumberMustSignalIllegalArgumentExceptionnull29 override fun required_spec309_requestNegativeNumberMustSignalIllegalArgumentException() { 30 } 31 }