Struct IncomingStreamManager 

pub struct IncomingStreamManager { /* private fields */ }

Implementations

impl IncomingStreamManager

pub fn new( reserved_topics: Vec<String>, ) -> (Self, UnboundedReceiver<(AnyStreamReader, String)>)

pub fn handle_header( &self, header: Header, identity: String, encryption_type: Type, )

Handles an incoming header packet.

pub fn is_internal(&self, stream_id: &str) -> bool

Returns whether the given open stream belongs to an internal topic (e.g. lk.rpc_request). Used to suppress RoomEvent::Stream*Received dispatches for traffic the SDK handles itself.

pub fn handle_chunk(&self, chunk: Chunk, encryption_type: Type)

Handles an incoming chunk packet.

pub fn handle_trailer(&self, trailer: Trailer)

Handles an incoming trailer packet.

Trait Implementations

impl Clone for IncomingStreamManager

fn clone(&self) -> IncomingStreamManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.