rust-stream-ext-concurrent
| Crates.io | rust-stream-ext-concurrent |
| lib.rs | rust-stream-ext-concurrent |
| version | 1.0.0 |
| source | src |
| created_at | 2024-01-11 09:31:47.470917 |
| updated_at | 2024-01-11 09:31:47.470917 |
| description | Concurrent behavior extensions for any futures::stream::Stream objects |
| homepage | |
| repository | https://github.com/hoprnet/rust-stream-ext-concurrent |
| max_upload_size | |
| id | 1096099 |
| size | 8,569 |
Tibor (Teebor-Choka)
documentation
README
rust-stream-ext-concurrent
Concurrent behavior extensions for any futures::stream::Stream objects.
Detail
A native Rust futures infrastructure futures::stream::FuturesUnordered is used to internally cache and enable concurrent processing of Stream objects.
Supported extensions
then_concurrentmethod extends everyStreamto add the desired functionality to use the concurrent execution capability ofFuturesUnordered