Registry / async / streamunordered

streamunordered

library0.5.5rscratesunverified

An efficient async stream multiplexer for merging multiple streams into one.

# Cargo.toml
[dependencies]
streamunordered = "0.5.5"

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · STREAMUNORDERED

streamunordered

asyncrustv0.5.5

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

StreamUnordered

✓ use streamunordered::StreamUnordered;

Creates a StreamUnordered, pushes two streams, and iterates over merged items.

use streamunordered::StreamUnordered; use futures::stream::{self, StreamExt}; #[tokio::main] async fn main() { let mut merged = StreamUnordered::new(); merged.push(stream::iter(vec![1, 2, 3])); merged.push(stream::iter(vec![4, 5, 6])); while let Some(item) = merged.next().await { println!("{}", item); } }

Debug

Known issues

gotchaRequires an async runtime like tokio or async-std to poll streams.

fix

Add tokio or async-std as a dependency and use #[tokio::main] or similar.

affects: >=0.5.0

Upgrade

Version history

0.5.5latest on crates.io

Audit

Dependencies

No dependency data recorded yet.

Agent activity

30 hits · last 30 days

node

Resources

githubhttps://github.com/jonhoo/streamunordered ↗

homepagehttps://github.com/jonhoo/streamunordered ↗

docshttps://docs.rs/streamunordered/ ↗