pekko
pekko copied to clipboard
apache
Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala
Motivation: Just like Java 's `orTimeout` method, which will cancel the future(if possible) and complete it with a timeout exception.
I think this class was introduced when Akka still supported Java versions before Java 8, which introduced `CompletionStage`. We should probably try and deprecate `org.apache.pekko.dispatch.Futures` and any Java APIs that...
see https://github.com/apache/pekko-persistence-cassandra/pull/212 there change that seems to have caused the issue is #1218 (and earlier #1186)
Motivation: I want to do some rate limiting and just fail the single task, eg when combined with `mapAsync`. Currently seems I can't observe the backpressure. `onBackpressure` is only been...
I noticed that the codebase has a lot of cases of redundant/useless braces, this scalafmt configuration removes all of these braces. When this gets merged In a future PR I...
(cherry picked from commit f9ad446a58dae77ccdec52719c5235e02ce8c770) Since this change has been determined to be completely safe (see https://github.com/apache/pekko/pull/1406#issuecomment-2241528879 and thread in general) I think its a good candidate to cherry pick...
continue #1386, separate PR for test migration
see #1327 This doesn't cause the test to fail or abort - for some reason testkit/scalatest logs the stackoverflow but then claims no tests were run. ``` Uncaught error from...
## Motivation https://github.com/apache/pekko/discussions/1354 ## Verification **Looks like it works!** the main branch's latest commit id: https://github.com/apache/pekko/commit/92b38e72d6a2701da06f483e8cd27953e403240e main branch ci  1.0.x branch's latest commit id: https://github.com/apache/pekko/commit/4f77c8108aaf548a65531d2c8807da13dbba8146 1.0.x...