pekko
pekko copied to clipboard
apache
Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala
* when we come around to doing an RC for pekko 1.3.0, we should upgrade netty * not worth cherry picking every netty upgrade from main, we can just upgrade...
Resolves: https://github.com/apache/pekko/issues/2404 This PR adds a zstd compression/decompression stream/flow using [zstd-jni](https://github.com/luben/zstd-jni), this project was chosen because its the only one that has high performance (it uses the [reference zstd implementation](https://github.com/facebook/zstd)...
* Currently users have to use JavaFlowSupport.Source and JavaFlowSupport.Sink instead * Still some doc changes to make * In particular, I need to create asJavaSubscriber.md and asJavaPublisher.md
``` [10-26 12:53:45.192] [info] - must resolve single A record *** FAILED *** (10 seconds, 26 milliseconds) [10-26 12:53:45.192] [info] The future returned an exception of type: org.apache.pekko.pattern.AskTimeoutException, with message:...
* We have PublisherSource and SubscriberSource but these are based on the org.reactivestreams API. We have other methods and classes to support the Java 9 equivalents but these involve delegating...
Motivation: refs: https://github.com/akka/akka-core/issues/22546 I encountered this when implementing the `doOnCancel`, but it seems `doOnCancel` can handle this. I got a quick prototype
eg: ``` case "BalancingDispatcher" => // FIXME remove this case in Akka 2.4 throw new IllegalArgumentException( "BalancingDispatcher is deprecated, use a BalancingPool instead. " + "During a migration period you...
This operator is been used in Spring ai, and I think it's actually useful than a map to Optional/Option and a then filter/collect
[zstd decompression/compression](https://en.wikipedia.org/wiki/Zstd) should be added a standard pekko IO stream as its far superior to gzip/lzma in every way. The API design should be the same as it is for...
Motivation: Make code much easy to find for daily job. refs: https://smallrye.io/smallrye-mutiny/latest/guides/reactive-to-imperative/#iterating-over-multis-items which has a `asStream` on Mutiny.