pekko
pekko copied to clipboard
apache
Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala
## About this PR 📦 Updates [com.eed3si9n:sbt-assembly](https://github.com/sbt/sbt-assembly) from `2.2.0` to `2.3.1` 📜 [GitHub Release Notes](https://github.com/sbt/sbt-assembly/releases/tag/v2.3.1) - [Version Diff](https://github.com/sbt/sbt-assembly/compare/v2.2.0...v2.3.1) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...
![scala-steward-asf[bot] avatar](https://avatars.githubusercontent.com/in/407462?v=4 "scala-steward-asf[bot] avatar"){kind=avatar}
Motivation: refs: https://github.com/apache/pekko/issues/1626
Relates to #1801 This commit introduces `Task`, a data structure that represents a recipe, or program, for producing a value of type T (or failing with an exception). It is...
This is a bug created on the pekko side for the issue here: https://github.com/akka/akka/issues/30170 In the following workflow, unstashed messages are enqueued in the mailbox but are not processed as...
Maybe implemented with `aggregateWithBoundary`? eg: ```java this.ollamaApi.pullModel(new PullModelRequest(modelName)) .bufferUntilChanged(OllamaApi.ProgressResponse::status) .doOnEach(signal -> { var progressResponses = signal.get(); if (!CollectionUtils.isEmpty(progressResponses) && progressResponses.get(progressResponses.size() - 1) != null) { logger.info("Pulling the '{}' model -...
Motivation: Even currently, we have `Source#unfold` and `Source#queue,` which is still a bit different from the Reactor's `Flux#create` method. When we want to control progress, we still make it lazy....
ThreadLocalRandom may not be a great idea if you are using Virtual Threads (#611). Java 17+ has a new RandomGenerator and we could allow users to choose via config which...
refs: https://github.com/apache/pekko/actions/runs/13755814627/job/38463002991?pr=1702#step:7:5426 ``` [03-10 03:03:26.191] [info] - must update the underutilizationStreak highestUtilization if current utilization is higher *** FAILED *** (1 millisecond) [03-10 03:03:26.191] [info] 1 was not equal to...