blob: d5a78e70de3f9e99e95538d209ecc5e571eb5444 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
//! Utilities used for the tor protocol.
pub(crate) mod ct;
pub(crate) mod err;
pub(crate) mod keyed_futures_unordered;
pub(crate) mod skew;
pub(crate) mod sometimes_unbounded_sink;
pub(crate) mod stream_poll_set;
pub(crate) mod ts;
use futures::Sink;
use std::pin::Pin;
use std::task::{Context, Poll};
/// Extension trait for `Sink`
pub(crate) trait SinkExt<T>: Sink<T> {
/// Calls `futures::Sink::poll_ready` but requires `Unpin` and returns `bool`
///
/// Various gnarly places in the circuit reactor find this convenient.
///
/// TODO #1397 (circuit reactor) probably remove this when the circuit reactor is rewritten.
fn poll_ready_unpin_bool(&mut self, cx: &mut Context<'_>) -> Result<bool, Self::Error>
where
Self: Unpin,
{
Ok(match Sink::poll_ready(Pin::new(self), cx) {
Poll::Ready(Ok(())) => true,
Poll::Ready(Err(e)) => return Err(e),
Poll::Pending => false,
})
}
}
impl<T, S: Sink<T>> SinkExt<T> for S {}
|
