pekko
pekko copied to clipboard
Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala
Just like with `EventSourcedBehavior`, it would be useful if runtime plugin configuration was possible for `DurableState`. https://github.com/apache/pekko-persistence-r2dbc/pull/194 adds the implementation for R2DBC plugin.
temporary test run but may be refactored later to run nightly
Bumps [VirtusLab/scala-cli-setup](https://github.com/virtuslab/scala-cli-setup) from 1.5.4 to 1.7.1. Release notes Sourced from VirtusLab/scala-cli-setup's releases. v1.7.1 What's Changed chore(deps-dev): Bump @types/node from 22.13.9 to 22.13.10 by @dependabot in VirtusLab/scala-cli-setup#771 chore(deps-dev): Bump eslint from...
In a pekko Java project I'm working on, I've been creating a `Task` class whose abstraction looks something like: ```java public abstract class Task { public static Task of(Supplier fn)...
…ator type. (#1707) * chore: Add support for controlling the NettyTransport's byteBuf allocator type. * chore: extract deriveByteBufAllocator method (cherry picked from commit dbc9ed3a99b0d97a697b705ceb927c48d72eea90) related thread: https://lists.apache.org/thread/6lj5lbg18hz4n9zckn0b89p9mv9nz14g
This is a meta issue, I will collect the operators needed to implement something like Spring Ai. [WIP] `switchMap` https://github.com/apache/pekko/pull/1787
Motivation: I have some cases when I'm using Flux. ```java if (resp == null) { return Flux.empty(); } else { return Flux.just(resp); } ``` There is an `Stream#ofNullable`, so I...
Hi I wanted to Query events by tag using EventsByTag with org.apache.pekko.persistence.testkit.query.javadsl.PersistenceTestKitReadJournal. Unfortunately this interface is not implemented yet. The scala-Version does implement EventsByTag. Is there a specific reason for...
* relates to #1749 * experimental new RandomNumberGenerator API that allows us to plug in different RandomGenerators based on the config (to be done) * so far, I'm just plugging...
https://github.com/search?q=repo%3Aapache%2Fpekko+%22Offsets+not+supported+for+persistence+test+kit%22&type=code