pekko
pekko copied to clipboard
apache
Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala
refs: https://github.com/apache/pekko/actions/runs/12621144995/job/35167661903?pr=1684#step:8:10432 ```scala [01-05 16:44:28.324] [info] - must be retried during handshake-timeout (no message loss) *** FAILED *** (7 seconds, 91 milliseconds) [01-05 16:44:28.324] [info] java.lang.AssertionError: assertion failed: timeout (6...
Motivation: Upstream https://github.com/apache/pekko-http/pull/462 and the `statefulMap` in pekko-http's `StreamUtils#statefulMap`. Seems like the PR is mostly ready.
Check for type pollution - can have a major performance impact. Basically, Java Runtime up to v23 has an issue in a secondary cache used internally to track results of...
Motivation: The original issue is https://github.com/apache/pekko/pull/1623 and https://github.com/apache/pekko/discussions/1566 , which do help find some problems, but with how the current interpreter and `concatAllLazy` are implemented, we can not fix the...
(cherry picked from commit 7fef5b75f3a4e435f572d870758f364e1d65a84c)
Motivation: refs: https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/distinct-until-changed.html Even it can be done with statefulMap, but seems better to support it out of box.
See this in testing: ``` No transport is loaded for protocol: [pekko], available protocols: [pekko.tcp] ``` https://github.com/apache/pekko/actions/runs/12528863513/job/34943874467#step:7:5682
@queimadus's report in https://github.com/apache/pekko/discussions/1566 refs: https://github.com/apache/pekko/pull/1623 and with the code below ```scala import org.apache.pekko.actor.ActorSystem import org.apache.pekko.stream.scaladsl.{Sink, Source} import org.apache.pekko.util.ByteString import scala.concurrent.Await object PekkoQuickstart extends App { private implicit val system:...
I hope the title is self-explanatory. Providing reflection metadata to Graal's native image generation would be a nice addition to the library. The Akka counterparts of the artifacts already had...
Motivation: refs: https://github.com/apache/pekko/issues/1591 Need to make sure `MultiJvm/test` pass. I was running `MultiJvm/test` code locally.