fire_stream/util/mod.rs
1mod timeout;
2pub(crate) mod watch;
3#[macro_use]
4pub mod bg_task;
5mod listener;
6pub mod testing;
7
8pub(crate) use timeout::TimeoutReader;
9pub use crate::standalone_util::*;
10pub use listener::{SocketAddr, Listener, ListenerExt};
11
12use tokio::io::{AsyncRead, AsyncWrite};
13
14/// A trait to simplify using all tokio io traits.
15pub trait ByteStream: AsyncRead + AsyncWrite + Send + Unpin + 'static {}
16impl<T> ByteStream for T
17where T: AsyncRead + AsyncWrite + Send + Unpin + 'static {}