You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hi,
we know have MergeUnbounded to merge an unbounded, growable list of streams. However it is not possible to remove streams from the list. futures_concurrency has a Keyed variant, where insert (push in MergeUnbounded) returns a Key that can be kept and passed to remove to remove streams from the group/merge. MergeUnbounded has much better performance than StreamGroup though, especially for large numbers of streams.
Is a Keyed variant of MergeUnbounded feasable? As removal is usually not a very frequent operation (in comparison to polling for the next item), I think it'd be fine for this to involve some iteration.
The text was updated successfully, but these errors were encountered:
Hi,
we know have
MergeUnbounded
to merge an unbounded, growable list of streams. However it is not possible to remove streams from the list.futures_concurrency
has aKeyed
variant, whereinsert
(push
inMergeUnbounded
) returns aKey
that can be kept and passed toremove
to remove streams from the group/merge.MergeUnbounded
has much better performance thanStreamGroup
though, especially for large numbers of streams.Is a
Keyed
variant ofMergeUnbounded
feasable? As removal is usually not a very frequent operation (in comparison to polling for the next item), I think it'd be fine for this to involve some iteration.The text was updated successfully, but these errors were encountered: