He-Pin(kerr)
He-Pin(kerr)
I think the `single(iterable).mapConcat(ConstantFun.scalaIdentityFunction).withAttributes(DefaultAttributes.iterableSource)` is too long The current `Source.fromIterable` is implemented with a `single` and `StatefulMapConcat`, when the upstream's `SingleSource` is completed, the internal state of `StatefulMapConcat` is discarded...
refs: https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#transform-java.util.function.Function- This will make the syntax more fluent
refs: https://github.com/akka/akka/issues/23958 Partially fixed it, the combineMat up to 22 version may need some discussion
I think the currently `recoverWith` behavior is a little unexpected, should make it a retry only once? refs:https://github.com/akka/akka/issues/20123 And I just tested with Reactor whitch works as expected with :...
The current API is great with `fold` and `reduce` but I think it can be simpler with direct collector support. ```scala def collect[In, A, T](() => collector: java.util.stream.Collector[In, A, T]):...
I think the doc should rewrite with paradox:) In the next 2.7.0 release.
before : ``` private var upstreamFailed: OptionVal[Throwable] = OptionVal.None ``` after ``` OptionVal.None ``` source :akka.stream.impl.fusing.ActorGraphInterpreter.ActorOutputBoundary
As the scala-native will learn more from this project, and the scala-native current has scalafmt 2.4.2 enabled, let this project formatted with scalafmt will help for code sharing. refs:https://github.com/scala-js/scala-js/pull/2701 refs:https://github.com/scala-native/scala-native/issues/1787
I think if the `invokeWithMetadata` is not lazy ,then we should call `futureSource`.  the request has been sent with the `singleRequest` call.
By using the sbt-native-packager,we could package it as a service,I think that would be great to use. btw,is there anychange to extract the download provider,like using `axel` or `aria2c` to...