reduce timeout

getkyo · Dec 19, 2024 · 5a87bbb · 5a87bbb
1 parent df6c125
commit 5a87bbb
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 10 deletions.
diff --git a/kyo-reactive-streams/shared/src/test/scala/kyo/interop/flow/PublisherToSubscriberTest.scala b/kyo-reactive-streams/shared/src/test/scala/kyo/interop/flow/PublisherToSubscriberTest.scala
@@ -190,12 +190,10 @@ abstract private class PublisherToSubscriberTest extends Test:
                 subscriber2 <- streamSubscriber
                 subscriber3 <- streamSubscriber
                 subscriber4 <- streamSubscriber
-                gatherFiber <- Fiber.gather[Nothing, Unit, Any](List(
-                    subscriber1.stream.run.unit,
-                    subscriber2.stream.run.unit,
-                    subscriber3.stream.run.unit,
-                    subscriber4.stream.run.unit
-                ))
+                fiber1      <- Async.run(subscriber1.stream.run.unit)
+                fiber2      <- Async.run(subscriber2.stream.run.unit)
+                fiber3      <- Async.run(subscriber3.stream.run.unit)
+                fiber4      <- Async.run(subscriber4.stream.run.unit)
                 publisherFiber <- Async.run(Resource.run(
                     Stream(Emit.andMap(Chunk.empty)(emit(_, counter)))
                         .toPublisher
@@ -209,8 +207,11 @@ abstract private class PublisherToSubscriberTest extends Test:
                 ))
                 _ <- Clock.sleep(10.millis).map { fiber =>
                     fiber.onComplete(_ => publisherFiber.interrupt.unit).andThen(fiber)
-                }.map(_.get)
-                _ <- gatherFiber.get
+                }.map(_.getResult)
+                _ <- fiber1.getResult
+                _ <- fiber2.getResult
+                _ <- fiber3.getResult
+                _ <- fiber4.getResult
             yield assert(true)
             end for
         }

diff --git a/...tive-streams/shared/src/test/scala/kyo/interop/reactive-streams/StreamPublisherTest.scala b/...tive-streams/shared/src/test/scala/kyo/interop/reactive-streams/StreamPublisherTest.scala
@@ -8,7 +8,7 @@ import org.reactivestreams.tck.PublisherVerification
 import org.reactivestreams.tck.TestEnvironment
 import org.scalatestplus.testng.*
 
-final class StreamPublisherTest extends PublisherVerification[Int](new TestEnvironment(1000L)), TestNGSuiteLike:
+final class StreamPublisherTest extends PublisherVerification[Int](new TestEnvironment(10L)), TestNGSuiteLike:
     import AllowUnsafe.embrace.danger
     given Frame = Frame.internal
 

diff --git a/...ive-streams/shared/src/test/scala/kyo/interop/reactive-streams/StreamSubscriberTest.scala b/...ive-streams/shared/src/test/scala/kyo/interop/reactive-streams/StreamSubscriberTest.scala
@@ -12,7 +12,7 @@ import org.reactivestreams.tck.SubscriberWhiteboxVerification.WhiteboxSubscriber
 import org.reactivestreams.tck.TestEnvironment
 import org.scalatestplus.testng.*
 
-class StreamSubscriberTest extends SubscriberWhiteboxVerification[Int](new TestEnvironment(1000L)), TestNGSuiteLike:
+class StreamSubscriberTest extends SubscriberWhiteboxVerification[Int](new TestEnvironment(10L)), TestNGSuiteLike:
     import AllowUnsafe.embrace.danger
     private val counter = new AtomicInteger()