Luigi
Luigi
pretty busy week, pick up at national celebration holiday > @GreyPlane Please add the new operator to a new file as #31619
> I'm still not convinced this is a good idea since it is hard to reason about for the cases where parallelism > 1, and that it opens up for...
> I agree with the concerns raised here. We shouldn't go overboard with the stateful stuff, and combining with async (and parallelism > 1) will open a can of worms....
> I also think that many use cases where this would fit could be done by composed by existing operators (statefulMap + mapAsync for example). After a second thought I...
> @GreyPlane There is an issue about that : #18431 This looks like a really heavy one, I'll take a look when I have time.
uh, I just found this issue after I implemented[ my own sketchy version ](https://gist.github.com/GreyPlane/8a3ba1a8bf117f42e1a5fbba98bbbbe5) while my original goal was to achieve a similar short-circuit evaluation semantic of boolean for IO...
I found `jawn-fs2`, this module provide jawn async parser binding to fs2 stream, which provide a functional abstraction over streaming, also I quickly inspect its code, seems it doesn't require...
I wonder if it is possible to write a Buffer.peek(n: Int) which peek from current to n, and by that, is it easy to impl Merge via this, just change...
weird blocking issue scalapb/ScalaPB#1583
I think this is ready to go, the implementation itself is stable enough to review, while I'm still working on adding more tests and documentations.