You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2023/06/27 10:45:31 UTC
[incubator-pekko-connectors] 08/21: support ironmq on scala3 (#153)
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 380bb730a511ffb29fc5431394d7aaa949a30672
Author: PJ Fanning <pj...@users.noreply.github.com>
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 11685d406..f585fbe6c 100644
--- a/project/Dependencies.scala
+++ b/project/Dependencies.scala
@@ -315,7 +315,6 @@ object Dependencies {
))
val IronMq = Seq(
- crossScalaVersions -= Scala3,
libraryDependencies ++= Seq(
"org.apache.pekko" %% "pekko-http" % PekkoHttpVersion,
"org.mdedetrich" %% "pekko-stream-circe" % "0.0.0+94-dbf3173f-SNAPSHOT", // ApacheV2
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org