Trait MultiplexerHandleAction

pub trait MultiplexerHandleAction {
    // Required methods
    fn send_cursor_from(
        &self,
        mode: StreamMode,
        container: &Arc<LogsArtifactsContainer>,
    ) -> bool;
    fn close(&self);
    fn multiplexer_id(&self) -> usize;
}

Required Methods

fn send_cursor_from( &self, mode: StreamMode, container: &Arc<LogsArtifactsContainer>, ) -> bool

fn close(&self)

Notify the multiplexer that no new sub-streams will be arriving.

fn multiplexer_id(&self) -> usize

Implementors

impl MultiplexerHandleAction for MultiplexerHandle<CursorItem>

impl MultiplexerHandleAction for MultiplexerHandle<Arc<Data<Logs>>>