diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-05-30 18:31:44 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-05-30 18:31:44 +0000 |
| commit | c23a457e72abe608715ac76f076f47dc42af07a5 (patch) | |
| tree | 2772049aaf84b5c9d0ed12ec8d86812f7a7904b6 /vendor/gix-features/src/io.rs | |
| parent | Releasing progress-linux version 1.73.0+dfsg1-1~progress7.99u1. (diff) | |
| download | rustc-c23a457e72abe608715ac76f076f47dc42af07a5.tar.xz rustc-c23a457e72abe608715ac76f076f47dc42af07a5.zip | |
Merging upstream version 1.74.1+dfsg1.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'vendor/gix-features/src/io.rs')
| -rw-r--r-- | vendor/gix-features/src/io.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/vendor/gix-features/src/io.rs b/vendor/gix-features/src/io.rs index 405960c0b..fba273693 100644 --- a/vendor/gix-features/src/io.rs +++ b/vendor/gix-features/src/io.rs @@ -77,9 +77,9 @@ pub mod pipe { /// Returns the _([`write`][Writer], [`read`][Reader])_ ends of a pipe for transferring bytes, analogous to a unix pipe. /// /// * `in_flight_writes` defines the amount of chunks of bytes to keep in memory until the `write` end will block when writing. - /// If `None` or `0`, the `write` end will always block until the `read` end consumes the transferred bytes. - pub fn unidirectional(in_flight_writes: impl Into<Option<usize>>) -> (Writer, Reader) { - let (tx, rx) = std::sync::mpsc::sync_channel(in_flight_writes.into().unwrap_or(0)); + /// If `0`, the `write` end will always block until the `read` end consumes the transferred bytes. + pub fn unidirectional(in_flight_writes: usize) -> (Writer, Reader) { + let (tx, rx) = std::sync::mpsc::sync_channel(in_flight_writes); ( Writer { channel: tx, |