tor_proto/
stream.rs

1//! Tor stream handling.
2//!
3//! A stream is an anonymized conversation; multiple streams can be
4//! multiplexed over a single circuit.
5
6pub(crate) mod cmdcheck;
7pub(crate) mod flow_ctrl;
8
9#[cfg(any(feature = "hs-service", feature = "relay"))]
10pub(crate) mod incoming;
11
12pub(crate) mod queue;
13
14use tor_memquota::mq_queue::{self, MpscSpec};
15
16/// MPSC queue relating to a stream (either inbound or outbound), sender
17pub(crate) type StreamMpscSender<T> = mq_queue::Sender<T, MpscSpec>;
18/// MPSC queue relating to a stream (either inbound or outbound), receiver
19pub(crate) type StreamMpscReceiver<T> = mq_queue::Receiver<T, MpscSpec>;