weighted-select 0.1.1

futures::stream::Select with weights
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
# weighted-select

Usage:
```rust
use weighted_select::{self, IncompleteSelect};

let select = weighted_select::new()
    .append(fetch_from_a, 5)
    .append(fetch_from_b, 2)
    .append(fetch_from_c, 3)
    .build();
```

It produces a stream that combines three underlying streams (`fetch_from_*`) and polls them according to their weights (`5`, `2`, `3`). Each stream will be polled at most `weight` times consecutively.