[concurrency-interest] Flow API tools for working with cold observables

Pavel Rappo pavel.rappo at gmail.com
Wed Feb 24 11:47:21 EST 2016

Thanks Dávid, I don't have a luxury of using 3rd party libraries. I
wonder what would others say? Is the "coupling" I've described is
essential enough to become a part of Flow API along with
SubmissionPublisher or I am missing something and it could *easily* be
assembled from already existing java.util.concurrent objects?


On Wed, Feb 24, 2016 at 11:48 AM, Dávid Karnok <akarnokd at gmail.com> wrote:
> Popular reactive libraries have converters / ports to j.u.c.Flow already so
> you have the option to work with a plethora of operators over cold sources:
> https://github.com/akarnokd/RxJavaUtilConcurrentFlow
> https://github.com/reactor/reactor-core/blob/master/src/main/java/reactor/core/converter/FlowPublisherConverter.java
> 2016-02-24 12:29 GMT+01:00 Pavel Rappo <pavel.rappo at gmail.com>:
>> Hi,
>> I wonder if there are any plans on creating some intermediary working
>> between a
>> publisher and a subscriber that would take care of buffering? I believe it
>> might
>> become a common need for Flow API adopters as it seems to represent a
>> highly
>> reusable component. As I understand, j.u.c.SubmissionPublisher is not
>> particularly good for working with "cold" observables. It provides
>> buffering but
>> for a different reason and it also relies on "drop handling and/or
>> blocking" for
>> flow control. I don't think any of these options are particularly good
>> when
>> working with cold observables in a non-blocking fashion.
>> What is needed in its essence is a some kind of "elastic coupling" working
>> between 2 subscribers that effectively manages a steady flow of items
>> prefetching them (if stock drops below some level) from the input side and
>> transferring them to the output side.
>> -Pavel
>> _______________________________________________
>> Concurrency-interest mailing list
>> Concurrency-interest at cs.oswego.edu
>> http://cs.oswego.edu/mailman/listinfo/concurrency-interest
> --
> Best regards,
> David Karnok

More information about the Concurrency-interest mailing list