He-Pin(kerr)
He-Pin(kerr)
Motivation: less allocation. Result: less allocation Note: The code it's self seems only been used in tests.
Motivation: refs: https://github.com/apache/pekko/issues/1626
Test scala 3.3.6
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....
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...
…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...
Even the PekkoJdk9ForkJoinPool is on the final result jar, but it does not on the classpath. How to reproduce: 1. using Java 21 2. sbt console 3. ```scala Welcome to...