Struct oasis_core_runtime::enclave_rpc::demux::Demux

pub struct Demux { /* private fields */ }

Session demultiplexer.

Implementations

impl Demux

pub fn new( builder: Builder, max_sessions: usize, max_sessions_per_peer: usize, stale_session_timeout: i64, ) -> Self

Create new session demultiplexer.

pub fn set_session_builder(&self, builder: Builder)

Set the session builder to use.

pub async fn process_frame<W: Write>( &self, peer_id: Vec<u8>, data: Vec<u8>, writer: W, ) -> Result<(OwnedMutexGuard<MultiplexedSession<Vec<u8>>>, Option<Message>), Error>

Process a frame, returning the locked session guard and decoded message.

Any data that needs to be transmitted back to the peer is written to the passed writer.

pub fn close<W: Write>( &self, session: OwnedMutexGuard<MultiplexedSession<Vec<u8>>>, writer: W, ) -> Result<(), Error>

Closes the given session.

Any data that needs to be transmitted back to the peer is written to the passed writer.

pub fn reset(&self)

Resets all open sessions.