chore: use mapAsynPartitioned instead of own stage (#989)

akka · Sep 6, 2023 · c50f8f3 · c50f8f3
1 parent df22094
commit c50f8f3
Show file tree

Hide file tree

Showing 4 changed files with 79 additions and 305 deletions.
diff --git a/...ts/src/test/scala/akka/projection/grpc/replication/internal/ParallelUpdatesFlowSpec.scala b/...ts/src/test/scala/akka/projection/grpc/replication/internal/ParallelUpdatesFlowSpec.scala
diff --git a/...ction-grpc/src/main/mima-filters/1.5.0-M3.backwards.excludes/ParallelUpdatesFlow.excludes b/...ction-grpc/src/main/mima-filters/1.5.0-M3.backwards.excludes/ParallelUpdatesFlow.excludes
@@ -0,0 +1,4 @@
+# internals
+ProblemFilters.exclude[MissingClassProblem]("akka.projection.grpc.replication.internal.ParallelUpdatesFlow")
+ProblemFilters.exclude[MissingClassProblem]("akka.projection.grpc.replication.internal.ParallelUpdatesFlow$")
+ProblemFilters.exclude[MissingClassProblem]("akka.projection.grpc.replication.internal.ParallelUpdatesFlow$Holder")
diff --git a/...n-grpc/src/main/scala/akka/projection/grpc/replication/internal/ParallelUpdatesFlow.scala b/...n-grpc/src/main/scala/akka/projection/grpc/replication/internal/ParallelUpdatesFlow.scala