He-Pin(kerr)

After talking to someone in CSUG, they want something like Spring Ai for Scala, the project is big for me to handle, but actually,we can add some missing stream operators...

chore: Add FutureOps which with an await style.

15

Motivation: I found the `Await.result` is everywhere. Modification: Add an `await` operator to the future. Result: Fluent code. ```scala [info] Benchmark (pool) (recursion) (threads) Mode Cnt Score Error Units [info]...

It's very annoying when you add a field in class and then mima breaks , https://github.com/com-lihaoyi/unroll can help. refs: https://github.com/scala/scala3/pull/21693 refs: https://github.com/scala/improvement-proposals/pull/78

Much pain on Java 8 refs: https://openjdk.org/jeps/472 refs: https://openjdk.org/jeps/471 We will soon face this, VarHandle only exists in Java 9.

I just found this in DAML, and was expected to implement it too.

refs: https://github.com/apache/pekko/actions/runs/12837234599/job/35800491988?pr=1724#step:7:5795 ```scala 01-17 21:46:48.292] [info] - must respect the throughput setting *** FAILED *** (10 seconds, 46 milliseconds) [01-17 21:46:48.292] [info] DispatcherActorSpec.this.convertToCheckingEqualizer[scala.Long](latch.getCount()).===[scala.Long](0L)(DispatcherActorSpec.this.typeCheckedConstraint[scala.Long, scala.Long](org.scalactic.Equivalence.default[scala.Long], scala.

Motivation: Currently, I have to use the `unfoldReosurce()` to integrate with a blocking queue. I think it would be nice to have this out of the box.

Failed: Address already in use

1

https://github.com/apache/pekko/actions/runs/12612621246/job/35149558293?pr=1678#step:7:10560 I think we should wait a little when do `disassociate` ```scala org.apache.pekko.remote.RemoteTransportException: Startup failed at org.apache.pekko.remote.Remoting.org$apache$pekko$remote$Remoting$$notifyError(Remoting.scala:174) at org.apache.pekko.remote.Remoting.start(Remoting.scala:250) at org.apache.pekko.remote.RemoteActorRefProvider.init(RemoteActorRefProvider.scala:274) at org.apache.pekko.actor.ActorSystemImpl._start$lzyINIT1(ActorSystem.scala:1043) at org.apache.pekko.actor.ActorSystemImpl._start(ActorSystem.scala:1039) at org.apache.pekko.actor.ActorSystemImpl.start(ActorSystem.scala:1062) at org.apache.pekko.actor.ActorSystem$.apply(ActorSystem.scala:283) at...

Deprecate the `org.apache.pekko.japi.Function` in 1.2.0

6

There are : ``` org.apache.pekko.japi.Function ``` and ``` org.apache.pekko.japi.function.Function ``` we should deprecate all of it in `org.apache.pekko.japi.Function` and remove it in the next release.

refs: https://github.com/apache/pekko/actions/runs/12621144995/job/35167661903?pr=1684#step:8:10432 ```scala [01-05 16:44:28.324] [info] - must be retried during handshake-timeout (no message loss) *** FAILED *** (7 seconds, 91 milliseconds) [01-05 16:44:28.324] [info] java.lang.AssertionError: assertion failed: timeout (6...