mirrors/arti.git/crates/tor-proto/src/util, branch arti-v1.3.0

tor-proto: Remove the no-longer needed allows

2024-10-03T14:10:47Z

tor-proto: Provide a variant for memquota errors

2024-10-03T14:10:35Z

tor-proto: SometimesUnboundedSink: provide as_inner accessor

2024-10-02T15:05:12Z

Fix typos

2024-09-03T08:09:02Z

extract tor_async_utils::oneshot into ::oneshot-fused-workaround

2024-08-28T14:27:46Z

Having this in the `tor-async-utils` crate prevents us from doing both of the following without introducing a circular dependency: * using it in `tor-rtmock` (which we currently do, particularly in tests). * using `tor-rtmock` to test things in `tor-async-utils`. We don't do this yet, but it is generally sensible to do so. In particular we want to move the `stream_peak` module there, which is currently tested with `tor-rtmock`. Moving this into its own crate avoids this circular dependency.

StreamPollSet: disallow polling ready streams

2024-08-21T18:30:55Z

tor-proto: Use PeekableStream to get rid of redundant buffering

2024-08-21T18:30:55Z

* Update `StreamPollSet` to require that its streams implement `PeekableStream`, and to not do its own buffering of values read from the stream. This avoids an extra layer of buffering for streams that already buffer a value, and makes the interior state a little simpler and more robust. It does have a downside of making the API a little less convenient, since the caller must do its own `poll_peek` call if it wants a reference to the item. * Update `StreamMap` to implement `PeekableStream` for `OpenStreamEntStream`, as it must to satisfy the updated `StreamPollSet` API. We have to somewhat constrain the `poll_ready_streams_iter` API to no longer return both a reference to the stream and the message. I don't see a way to return both while satisfying the borrow checker. Luckily we don't really need both anymore. * Update the Circuit reactor to handle the updated `StreamMap::poll_ready_streams_iter` API.

StreamPollSet: remove redundant type parameter V

2024-08-12T21:26:36Z

This was required to be the same type as `S::Item`. We can just use `S::Item` directly.

StreamPollSet: replace nested Option

2024-08-08T21:30:21Z

Bullied by clippy. I'm on the fence whether this is actually an improvement, or whether I should add an exception. ``` error: consider using `Option` instead of `Option>` or a custom enum if you need to distinguish all 3 cases --> crates/tor-proto/src/util/stream_poll_set.rs:106:56 | 106 | pub fn remove(&mut self, key: &K) -> Option<(K, P, Option>, S)> { | ^^^^^^^^^^^^^^^^^ | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#option_option = note: `-D clippy::option-option` implied by `-D warnings` = help: to override `-D warnings` add `#[allow(clippy::option_option)]` ```

StreamMap: Merge rxs into open_streams

2024-08-08T21:30:21Z

This simplifies the bookkeeping a bit, and clears a path towards updating the Streams in our StreamPollSet to directly respect flow control.