Reputation: 32335
I'm trying to use the java.util.concurrent.flow
, and I need an implementation that copies elements from one input flow to two output flows - aka "teeing".
The Java Stream API (java.util.stream
) has a "Teeing Collector" (Collectors.teeing()
) that does basically that, so I expected there to also be a "teeing flow" implementation somewhere, but I can't find it, nor Google searching helped any.
If you are familiar with such an implementation - or have written such - I would appreciate being pointed at it, or if you have any pointers for implementing this myself (which I'm currently wary I'll have to) - that would also be greatly appreciated.
Upvotes: 0
Views: 39