Skip to content

Commit b8cd791

Browse files
halotukozakclaude
andcommitted
fix: add scalatestplus-testng dep and Dispatcher[Task] for reactive-streams TCK
The reactive-streams TCK tests require scalatestplus-testng for the TestNG/ScalaTest bridge, and CE3's Iterant.toReactivePublisher now requires an implicit Dispatcher[Task]. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent 54bdc4c commit b8cd791

2 files changed

Lines changed: 13 additions & 1 deletion

File tree

build.sbt

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -705,7 +705,8 @@ lazy val reactiveTests = project
705705
.dependsOn(reactiveJVM, tailJVM)
706706
.settings(
707707
libraryDependencies ++= Seq(
708-
reactiveStreamsTCKLib % Test
708+
reactiveStreamsTCKLib % Test,
709+
"org.scalatestplus" %% "testng-7-5" % "3.2.17.0" % Test
709710
)
710711
)
711712

reactiveTests/src/test/scala/monix/reactiveTests/IterantToPublisherTest.scala

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,8 @@
1818
package monix.reactiveTests
1919

2020
import cats.effect.Sync
21+
import cats.effect.std.Dispatcher
22+
import cats.effect.unsafe.implicits.{global => ioRuntime}
2123
import monix.execution.Scheduler.Implicits.global
2224
import monix.eval.Task
2325
import monix.execution.exceptions.DummyException
@@ -33,6 +35,15 @@ import scala.util.Random
3335
class IterantToPublisherTest extends PublisherVerification[Long](env())
3436
with TestNGSuiteLike {
3537

38+
// CE3 Dispatcher[Task] required for toReactivePublisher
39+
implicit val taskDispatcher: Dispatcher[Task] = new Dispatcher[Task] {
40+
import monix.execution.Scheduler.Implicits.global as s
41+
def unsafeToFutureCancelable[A](fa: Task[A]): (scala.concurrent.Future[A], () => scala.concurrent.Future[Unit]) = {
42+
val cf = fa.runToFuture(s)
43+
(cf, () => { cf.cancel(); scala.concurrent.Future.successful(()) })
44+
}
45+
}
46+
3647
def createPublisher(elements: Long): Publisher[Long] = {
3748
if (elements < 4096) {
3849
val list: List[Long] = (0 until elements.toInt).map(_.toLong).toList

0 commit comments

Comments
 (0)