[−][src]Crate weighted_select
An adapter for merging the output of several streams with priority.
The merged stream produces items from either of the underlying streams as they become available, and the streams are polled according to priority.
Example:
use weighted_select::{self, IncompleteSelect}; let select = weighted_select::new() .append(iter_ok::<_, ()>(vec![1u32, 1]), 1) .append(iter_ok(vec![2, 2, 2, 2, 2]), 3) .append(iter_ok(vec![3, 3, 3, 3]), 2) .build(); let actual = select.wait().collect::<Result<Vec<_>, _>>().unwrap(); assert_eq!(actual, vec![1, 2, 2, 2, 3, 3, 1, 2, 2, 3, 3]);
Structs
Select | An adapter for merging the output of several streams with priority. |
SelectPart |
Traits
IncompleteSelect |
Functions
new |