This is an automated email from the ASF dual-hosted git repository. fanningpj pushed a commit to branch scala3 in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
commit 876ee6ff7603d4d4c0a1c0eb1167ea99b9f783de Author: PJ Fanning <[email protected]> AuthorDate: Sat Jun 10 12:45:41 2023 +0100 support ironmq on scala3 (#153) --- .../stream/connectors/ironmq/scaladsl/IronMqProducerSpec.scala | 10 +++++----- project/Dependencies.scala | 1 - 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqProducerSpec.scala b/ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqProducerSpec.scala index 677593bd2..1e92241b3 100644 --- a/ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqProducerSpec.scala +++ b/ironmq/src/test/scala/org/apache/pekko/stream/connectors/ironmq/scaladsl/IronMqProducerSpec.scala @@ -80,11 +80,11 @@ class IronMqProducerSpec extends IronMqSpec { new MockCommittable, new MockCommittable) - whenReady( - messages - .zip(Source(committables)) - .via(atLeastOnceFlow(queue, settings, Flow[Committable].mapAsync(1)(_.commit()))) - .runWith(Sink.ignore)) { _ => + val future: Future[Done] = messages + .zip(Source(committables)) + .via(atLeastOnceFlow(queue, settings, Flow[Committable].mapAsync(1)(_.commit()))) + .runWith(Sink.ignore) + whenReady(future) { _ => committables.forall(_.committed) shouldBe true } } diff --git a/project/Dependencies.scala b/project/Dependencies.scala index 110560467..7911b958d 100644 --- a/project/Dependencies.scala +++ b/project/Dependencies.scala @@ -298,7 +298,6 @@ object Dependencies { "org.influxdb" % "influxdb-java" % InfluxDBJavaVersion)) val IronMq = Seq( - crossScalaVersions -= Scala3, libraryDependencies ++= Seq( "org.apache.pekko" %% "pekko-http" % PekkoHttpVersion, "org.mdedetrich" %% "pekko-stream-circe" % "1.0.0", --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
