He-Pin(kerr)

```scala //scalafix:off //#imports import scala.collection.immutable import scala.concurrent.duration._ import scala.concurrent.{ Await, Future } import org.scalatest.wordspec.AnyWordSpecLike import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit import akka.actor.typed.ActorRef //#imports //scalafix:on import akka.actor.typed.scaladsl.Behaviors ``` gives me ```scala //scalafix:off //#imports import scala.collection.immutable...

Add Fold with resource for Sink

8

References https://github.com/akka/akka/issues/21526 Should this method be named with `foldResource` ,`foldWithResource` or `toResource`? I personally prefer `foldWithResource` previous prs: https://github.com/akka/akka/pull/21554 https://github.com/akka/akka/pull/26393 built on top of https://github.com/akka/akka/pull/31361 NOTE: I built it with...

JDK 19 is released with Loom https://jdk.java.net/19/ And they may plan to remove `Continuation` in future, so it should be better to use Virutal Thread directly?

Add BoundedSourceQueue.isQueueCompleted to check is the queue is completed before offering?

1

How about add a method `BoundedSourceQueue.isQueueCompleted` to check if the queue is already completed , so we can check before offer a message to it?

Should `create` be called only there is a pull, in `UnfoldResourceSource` `UnfoldResourceSourceAsync` and `StatefulMap` ?

1

Currently the `create` is called in `preStart`, is it better to only call it when the first `pull` arrives? But then , the `Resource/State` can be null when the `close`...

Optimize flatMapConcat for iterable and empty source.

1

A follow up of https://github.com/akka/akka/pull/31372. refs: https://github.com/akka/akka/issues/21462 Draft status, just make the test pass and the `SupervisionStrategy` is not handle If this is acceptable I will try with `Source.fromFuture` later...

References https://github.com/akka/akka/issues/31610 As we don't expect exception to throw.

We use our own where we want to allow throwing checked exceptions, like in actor message handling where it makes sense, but here the JDK ones makes more sense indeed....

References https://github.com/akka/akka/issues/31577

=str Optimize performance of MapAsyncUnordered(1).

20

Run with > jmh:run -i 20 -wi 20 -f1 -t1 .*MapAsyncBenchmark.* I adjusted it a little to just run with `1`. Before: ``` [info] Iteration 20: 2022-09-11 17:14:30,867 INFO akka.actor.CoordinatedShutdown...