Struct solicit::http::session::DefaultSessionState

pub struct DefaultSessionState<T, S> where
    S: Stream,  { /* fields omitted */ }

An implementation of the SessionState trait that tracks the active streams in a HashMap, mapping the stream ID to the concrete Stream instance.

Implementations

impl<S> DefaultSessionState<Client, S> where
    S: Stream, 

pub fn new() -> DefaultSessionState<Client, S>

Creates a new DefaultSessionState for a client session with no known streams.

impl<S> DefaultSessionState<Server, S> where
    S: Stream, 

pub fn new() -> DefaultSessionState<Server, S>

Creates a new DefaultSessionState for a server session with no known streams.

Trait Implementations

impl<T, S> SessionState for DefaultSessionState<T, S> where
    S: Stream, 

type Stream = S

The type of the Stream that the SessionState manages.

fn insert_outgoing(&mut self, stream: Self::Stream) -> StreamId

Inserts the given Stream into the session's state, starting to track it. The SessionState should assign it the next available outgoing stream ID.

fn insert_incoming(
    &mut self,
    stream_id: StreamId,
    stream: Self::Stream
) -> Result<(), ()>

Inserts the given Stream into the session's state, considering it an incoming stream. TODO(mlalic): Allow the exact error to propagate out.

fn get_stream_ref(&self, stream_id: StreamId) -> Option<&Self::Stream>

Returns a reference to a Stream with the given StreamId, if it is found in the current session.

fn get_stream_mut(&mut self, stream_id: StreamId) -> Option<&mut Self::Stream>

Returns a mutable reference to a Stream with the given StreamId, if it is found in the current session.

fn remove_stream(&mut self, stream_id: StreamId) -> Option<Self::Stream>

Removes the stream with the given StreamId from the session. If the stream was found in the session, it is returned in the result.

fn iter(&mut self) -> StreamIter<S>

Returns an iterator over the streams currently found in the session.

fn len(&self) -> usize

Number of currently active streams

fn get_closed(&mut self) -> Vec<Self::Stream>

Returns all streams that are closed and tracked by the session state.