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/10 11:45:46 UTC
[incubator-pekko-connectors] branch scala3 updated: 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
The following commit(s) were added to refs/heads/scala3 by this push:
new ac0618325 support ironmq on scala3 (#153)
ac0618325 is described below
commit ac0618325e9895ba545d2e9acec7477a9aa3803b
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 7ea34d67b..9bf875f04 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 1196decae..9021b7bc9 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