//! Utilities used for the tor protocol.

pub(crate) mod ct;

pub(crate) mod err;

pub(crate) mod keyed_futures_unordered;

pub(crate) mod notify;

pub(crate) mod oneshot_broadcast;

pub(crate) mod poll_all;

pub(crate) mod sink_blocker;

pub(crate) mod skew;

pub(crate) mod sometimes_unbounded_sink;

pub(crate) mod stream_poll_set;

pub(crate) mod timeout;

pub(crate) mod token_bucket;

pub(crate) mod ts;

pub(crate) mod tunnel_activity;

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.

    {

        })

}

impl<T, S: Sink<T>> SinkExt<T> for S {}

/// Convenience alias for

/// [`memquota::SpecificAccount::new_noop()`](crate::memquota::SpecificAccount::new_noop())

///

/// Available only in tests, which makes diff hunks which call this more obviously correct.

#[cfg(any(test, feature = "testing"))]

/// A timeout estimator that returns dummy values.

///

/// Used in the tests where the timeout estimates aren't relevant.

#[cfg(test)]

pub(crate) struct DummyTimeoutEstimator;

#[cfg(test)]

impl crate::client::circuit::TimeoutEstimator for DummyTimeoutEstimator {

        // Dummy value

}