He-Pin(kerr)

Results 338 issues of He-Pin(kerr)

When use `scala-cli fmt`, it will fail because there is no native image. ``` PS C:\Users\hepin\IdeaProjects\akka> scala-cli fmt Error: coursier.error.ResolutionError$CantDownloadModule: Error downloading org.scalameta:scalafmt-cli_2.13:2.1.0 not found: C:\Users\hepin\.ivy2\local\org.scalameta\scalafmt-cli_2.13\2.1.0\ivys\ivy.xml not found: https://repo1.maven.org/maven2/org/scalameta/scalafmt-cli_2.13/2.1.0/scalafmt-cli_2.13-2.1.0.pom ```

References https://github.com/akka/akka/issues/31958 was: https://github.com/akka/akka/pull/31602 I ran the tests after changing the default `flatMapConcat` to `FlattenConcat`; the tests passed, too. ``` [info] FlatMapConcatBenchmark.completedFuture thrpt 5 832464.979 ± 1045741.316 ops/s [info] FlatMapConcatBenchmark.completedFutureP1...

t:stream

Motivation: As a daily Java developer , I think the `onError*` operators are very easy to use, that may not apply to Scaladsl. eg: https://github.com/spring-projects/spring-framework/pull/31352 refs:https://github.com/reactor/reactor-core/issues/535 refs: https://github.com/akka/akka/issues/24992 Currently: |Reactor-core|Pekko|Suggestion|...

As the guide here:https://github.com/akka/akka/blob/main/CONTRIBUTING.md#overview-of-scala-types-and-their-java-counterparts

1 - triaged
help wanted
t:stream
t:java

Remove deprecated methods in GraphStage since 2.6.0

t:stream

Motivation: I find this pattern in some of our internal codebase, which is more like `statefulMap(..).collect{case Some(x) => x}` and I find the Kotlin has Flow#distinctUntilChanged too. ```scala def distinctUtilChanged:Repr[Out]...

0 - new
t:stream

A part of https://github.com/akka/akka/issues/31553 I think which would be very helpful and esseintial.

0 - new
t:stream

In Java 9 release, Jdk introduce `Stream.iterate` as a simpler and less powerful `unfold`, one advantage of it is less allocation, especially in Java. It would be great to have...

0 - new
t:stream

There already is `Source.single` and we can use it as `Source.single(())` which returns an `Source[Unit]`, but things become harder when try to use it directly in Java. I think which...

0 - new

It was a little refractory when reading the code