Skip to content

Commit 47c965e

Browse files
committed
clarify streaming concurrency
1 parent 095ec15 commit 47c965e

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/lib.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -92,16 +92,16 @@
9292
//! Streams yield outputs one-by-one, which means that deciding to stop iterating is
9393
//! the same for fallible and infallible streams. The operations provided for
9494
//! streams can be categorized based on whether their inputs can be concurrently
95-
//! processed, and whether their outputs can be concurrently processed.
95+
//! evaluated, and whether their outputs can be concurrently processed.
9696
//!
9797
//! Specifically in the case of `merge`, it takes `N` streams in, and yields items
9898
//! one-by-one as soon as any are available. This enables the output of individual
9999
//! streams to be concurrently processed by further operations later on.
100100
//!
101-
//! | | __Sequential processing__ | __Concurrent processing__ |
102-
//! | ------------------------ | --------------------- | --------------------- |
103-
//! | __Sequential execution__ | `Stream::chain` | *not yet available* ‡ |
104-
//! | __Concurrent execution__ | `Stream::zip` | `Stream::merge` |
101+
//! | | __Sequential output processing__ | __Concurrent output processing__ |
102+
//! | ------------------------------- | -------------------------------- | -------------------------------- |
103+
//! | __Sequential input evaluation__ | `Stream::chain` | *not yet available* ‡ |
104+
//! | __Concurrent input evaluation__ | `Stream::zip` | `Stream::merge` |
105105
//!
106106
//! ‡: _This could be addressed by a hypothetical `Stream::unzip` operation,
107107
//! however because we aspire for semantic compatibility with `std::iter::Iterator`

0 commit comments

Comments
 (0)