Johan Andrén
Johan Andrén
Its controlled by the input buffer attribute. You can read more here: https://doc.akka.io/docs/akka/current/stream/stream-rate.html#internal-buffers-and-their-effect
I think it isn't in the javadoc because it is not something specific the reactive stream integration but applies anywhere there is an async boundary, so it is more something...
Ah, I see, there is something funky with input buffer (or all attributes) for `Source.fromPublisher`, if I set the attributes on the whole graph, it correctly picks it up: ```...
Quite a deep end to get your feet wet in, just as a warning :) Isn't the `SourceModulePhase` used in this case since `PublisherSource` is a `SourceModule`? In that case...
I agree that the change was questionable, so maybe we should indeed revert. I think I've seen some reports of _other_ usage where tight buffer control has been expected that...
I think sounds like a good idea. What about `foldResource`/`foldResourceAsync` perhaps, because it would be the opposite of the `unfoldResource`, and would be more like fold than foreach, as it...
Go ahead! :)
`Future[Done]` sounds good to me.
Hmm, gut feeling is that doing some early cancel is better done with some form of upstream operator (like `takeWhile`) and that in the few cases where that would be...