pekko
pekko copied to clipboard
apache
Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala
This PR adds `optionalVia`/`unsafeOptionalVia` functions which allows you to apply a `viaFlow` to elements in the stream only if they are defined. This kind of utility function has cropped up...
See #1421 This is WIP and needs more tests. I'm opening this to give a preview of what I am proposing. The docs in https://cwiki.apache.org/confluence/display/PEKKO/Pekko+Akka+Compatibility can be updated when this...
extends #1299 @He-Pin could you review my additional changes? needed #1434 to ensure the new test is actually run in CI builds for PRs
## Motivation I am using Pattern#retry to ensure reliable delivery to my actor, and my actor has backoff supervisor. my demand is support backoff retry on Pattern, which align my...
See https://github.com/apache/pekko/pull/1432 - I deliberately modified 2 classes (1 Java, 1 Scala) to see if they were even compiled. The PR did fail because scalafmt and the doc build failed...
Motivation: refs: https://github.com/apache/pekko/issues/1359 still wip, test is missing
Try build with latest Aeron and Agrona libs. Aeron 1.46.0 needs Java 17.
Hi today I've found a bug regarding name attribute overriding in `SourceQueueWithComplete`. If I create a `Source.queue` like this `Source.queue[Int](10, OverflowStrategy.dropHead)` It calls following method: ``` def queue[T]( bufferSize: Int,...
Currently, dependency-submission would submit all dependencies to https://github.com/apache/pekko/security/dependabot , including test dependencies. We then added explicit dependencies to the build to squash warnings about outdated test dependencies (#1181, #1313 and...
Sketching out #1417 - incomplete and notably not bothering with binary compatibility yet, just to illustrate the idea.