1 //! Wrappers for Tokio types that implement `Stream`. 2 3 /// Error types for the wrappers. 4 pub mod errors { 5 cfg_sync! { 6 pub use crate::wrappers::broadcast::BroadcastStreamRecvError; 7 } 8 } 9 10 mod mpsc_bounded; 11 pub use mpsc_bounded::ReceiverStream; 12 13 mod mpsc_unbounded; 14 pub use mpsc_unbounded::UnboundedReceiverStream; 15 16 cfg_sync! { 17 mod broadcast; 18 pub use broadcast::BroadcastStream; 19 20 mod watch; 21 pub use watch::WatchStream; 22 } 23 24 cfg_signal! { 25 #[cfg(unix)] 26 mod signal_unix; 27 #[cfg(unix)] 28 pub use signal_unix::SignalStream; 29 30 #[cfg(any(windows, docsrs))] 31 mod signal_windows; 32 #[cfg(any(windows, docsrs))] 33 pub use signal_windows::{CtrlCStream, CtrlBreakStream}; 34 } 35 36 cfg_time! { 37 mod interval; 38 pub use interval::IntervalStream; 39 } 40 41 cfg_net! { 42 mod tcp_listener; 43 pub use tcp_listener::TcpListenerStream; 44 45 #[cfg(unix)] 46 mod unix_listener; 47 #[cfg(unix)] 48 pub use unix_listener::UnixListenerStream; 49 } 50 51 cfg_io_util! { 52 mod split; 53 pub use split::SplitStream; 54 55 mod lines; 56 pub use lines::LinesStream; 57 } 58 59 cfg_fs! { 60 mod read_dir; 61 pub use read_dir::ReadDirStream; 62 } 63