This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-persistence-cassandra.git
The following commit(s) were added to refs/heads/main by this push:
new ec7645a remove ActorMaterializer (#108)
ec7645a is described below
commit ec7645a284bc05b52b0a296686c6458fcdd28a1c
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Oct 30 12:30:31 2023 +0000
remove ActorMaterializer (#108)
---
.../pekko/cluster/persistence/cassandra/EventsByTagMultiJvmSpec.scala | 2 --
1 file changed, 2 deletions(-)
diff --git
a/core/src/multi-jvm/scala/org/apache/pekko/cluster/persistence/cassandra/EventsByTagMultiJvmSpec.scala
b/core/src/multi-jvm/scala/org/apache/pekko/cluster/persistence/cassandra/EventsByTagMultiJvmSpec.scala
index 26133e9..f1545e6 100644
---
a/core/src/multi-jvm/scala/org/apache/pekko/cluster/persistence/cassandra/EventsByTagMultiJvmSpec.scala
+++
b/core/src/multi-jvm/scala/org/apache/pekko/cluster/persistence/cassandra/EventsByTagMultiJvmSpec.scala
@@ -16,7 +16,6 @@ import pekko.persistence.cassandra.testkit.CassandraLauncher
import pekko.persistence.journal.Tagged
import pekko.persistence.query.{ NoOffset, PersistenceQuery }
import pekko.remote.testkit.{ MultiNodeConfig, MultiNodeSpec }
-import pekko.stream.ActorMaterializer
import pekko.stream.testkit.TestSubscriber
import pekko.stream.testkit.scaladsl.TestSink
import org.scalatest.matchers.should.Matchers
@@ -100,7 +99,6 @@ abstract class EventsByTagMultiJvmSpec
"be readable across nodes" in {
- implicit val materializer: ActorMaterializer =
ActorMaterializer()(system)
val queryJournal =
PersistenceQuery(system).readJournalFor[CassandraReadJournal](CassandraReadJournal.Identifier)
var readers: Seq[(Int, TestSubscriber.Probe[(String, Int)])] = Nil
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
