1 mod connection; 2 mod error; 3 mod go_away; 4 mod peer; 5 mod ping_pong; 6 mod settings; 7 mod streams; 8 9 pub(crate) use self::connection::{Config, Connection}; 10 pub(crate) use self::error::Error; 11 pub(crate) use self::peer::{Peer, Dyn as DynPeer}; 12 pub(crate) use self::ping_pong::UserPings; 13 pub(crate) use self::streams::{StreamRef, OpaqueStreamRef, Streams}; 14 pub(crate) use self::streams::{PollReset, Prioritized, Open}; 15 16 use codec::Codec; 17 18 use self::go_away::GoAway; 19 use self::ping_pong::PingPong; 20 use self::settings::Settings; 21 22 use frame::{self, Frame}; 23 24 use futures::{task, Async, Poll}; 25 use futures::task::Task; 26 27 use bytes::Buf; 28 29 use tokio_io::AsyncWrite; 30 31 pub type PingPayload = [u8; 8]; 32 33 pub type WindowSize = u32; 34 35 // Constants 36 pub const MAX_WINDOW_SIZE: WindowSize = (1 << 31) - 1; 37 pub const DEFAULT_RESET_STREAM_MAX: usize = 10; 38 pub const DEFAULT_RESET_STREAM_SECS: u64 = 30; 39