pekko 1.0.2

Fix deprecation warning with statefulMapConcat.
Netflix · Dec 6, 2023 · 4bd98dc · 4bd98dc
1 parent 6e60aeb
commit 4bd98dc
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 9 deletions.
diff --git a/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/SubscribeApi.scala b/atlas-lwcapi/src/main/scala/com/netflix/atlas/lwcapi/SubscribeApi.scala
@@ -110,14 +110,11 @@ class SubscribeApi(
       .via(new WebSocketSessionManager(streamMeta, register, subscribe))
       .flatMapMerge(Int.MaxValue, msg => msg)
       .groupedWithin(batchSize, 1.second)
-      .statefulMapConcat { () =>
-        // Re-use the stream to reduce allocations
-        val baos = new ByteArrayOutputStream()
-
-        { seq =>
-          List(BinaryMessage(LwcMessages.encodeBatch(seq, baos)))
-        }
-      }
+      .statefulMap(() => new ByteArrayOutputStream())(
+        (baos, seq) => baos -> List(BinaryMessage(LwcMessages.encodeBatch(seq, baos))),
+        _ => None
+      )
+      .mapConcat(identity)
       .watchTermination() { (_, f) =>
         f.onComplete {
           case Success(_) =>

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -4,7 +4,7 @@ import sbt._
 
 object Dependencies {
   object Versions {
-    val pekko       = "1.0.1"
+    val pekko       = "1.0.2"
     val pekkoHttpV  = "1.0.0"
     val iep        = "5.0.15"
     val jackson    = "2.16.0"