Crate async_selector 

Fast and flexible Future/Stream/task selector.

Designed for optimal performance when polling a large number of tasks (see example).

Allows for:

1. Polling multiple tasks concurrently on the same thread
2. Safely injecting shared state into polling logic (see Pollable)
3. Accessing and removing the tasks by automatically assigned unique ids

Examples

Simply flatten a set of streams:

let mut selector = StreamSelector::default();
(0..5).for_each(|i| {
    let (tx, rx) = mpsc::unbounded();
    selector.push(rx);
    tx.unbounded_send(i).unwrap();
});
let collected = selector.collect::<Vec<_>>().await;
assert_eq!(
    collected,
    vec![0, 1, 2, 3, 4],
);

Use as a map of streams:

let mut selector = StreamSelector::default();
let txs = (0..10)
    .map(|_| {
        let (tx, rx) = mpsc::channel::<()>(8);
        let id = selector.push_with_id(rx);
        (tx, id)
    })
    .collect::<Vec<_>>();
for (mut tx, saved_id) in txs {
    tx.send(()).await.unwrap();
    let ((), received_id) = selector.with_id().next().await.unwrap();
    assert_eq!(received_id, saved_id);
}

More examples live here.

Modules

pollable

Traits that make the Selector generic over asynchronous tasks and polling logic.

selector

Fast and flexible Future/Stream selector.

Type Aliases

FutureSelector

Selector specialized for polling Futures.

StreamSelector

Selector specialized for polling Streams.