Struct h2::proto::streams::streams::Inner

struct Inner {
    counts: Counts,
    actions: Actions,
    store: Store,
    refs: usize,
}

Fields needed to manage state related to managing the set of streams. This is mostly split out to make ownership happy.

TODO: better name

Fields

counts: Counts

Tracks send & recv stream concurrency.

actions: Actions

Connection level state and performs actions on streams

store: Store

Stores stream state

refs: usize

The number of stream refs to this shared state.

Implementations

impl Inner

fn new(peer: Dyn, config: Config) -> Arc<Mutex<Self>>

fn recv_headers<B>( &mut self, peer: Dyn, send_buffer: &SendBuffer<B>, frame: Headers ) -> Result<(), Error>

fn recv_data<B>( &mut self, peer: Dyn, send_buffer: &SendBuffer<B>, frame: Data ) -> Result<(), Error>

fn recv_reset<B>( &mut self, send_buffer: &SendBuffer<B>, frame: Reset ) -> Result<(), Error>

fn recv_window_update<B>( &mut self, send_buffer: &SendBuffer<B>, frame: WindowUpdate ) -> Result<(), Error>

fn handle_error<B>( &mut self, send_buffer: &SendBuffer<B>, err: Error ) -> StreamId

fn recv_go_away<B>( &mut self, send_buffer: &SendBuffer<B>, frame: &GoAway ) -> Result<(), Error>

fn recv_push_promise<B>( &mut self, send_buffer: &SendBuffer<B>, frame: PushPromise ) -> Result<(), Error>

fn recv_eof<B>( &mut self, send_buffer: &SendBuffer<B>, clear_pending_accept: bool ) -> Result<(), ()>

fn poll_complete<T, B>( &mut self, send_buffer: &SendBuffer<B>, cx: &mut Context<'_>, dst: &mut Codec<T, Prioritized<B>> ) -> Poll<Result<()>>where T: AsyncWrite + Unpin, B: Buf,

fn send_reset<B>( &mut self, send_buffer: &SendBuffer<B>, id: StreamId, reason: Reason )

Trait Implementations

impl Debug for Inner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.