Hi Julia
Since short-circuiting sounds similar to a Subscriber cancelling its
Subscription, I believe it might be worthwhile to consider the Flow API.
If the argument would be a `Flow.Processor`, then the
implementation would publish instances of T to it, subscribe to receive
instances of R,
On 02/07/2020 16:38, Patrick Concannon wrote:
Hi Anthony,
Hi Patrick
Thanks for your suggestion of using a Stream.Builder instead of a Consumer.
Thanks for your response. Since Stream.Builder extends Consumer, I don't
see it as "instead of": the proposed signature is a strict superset of
the
