Struct MemoryStreamingChannel 

pub struct MemoryStreamingChannel { /* private fields */ }

Memory-based streaming channel implementation

Implementations

impl MemoryStreamingChannel

pub fn new(id: impl Into<String>, config: StreamingChannelConfig) -> Self

Create a new memory-based streaming channel

Trait Implementations

impl Clone for MemoryStreamingChannel

fn clone(&self) -> MemoryStreamingChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StreamingChannel for MemoryStreamingChannel

fn id(&self) -> &str

Get the channel ID

fn config(&self) -> &StreamingChannelConfig

Get the channel configuration

fn stats(&self) -> StreamingStats

Get the streaming statistics

fn is_open(&self) -> bool

Check if the channel is open

fn close(&self) -> Result<()>

Close the channel

impl StreamingChannel2Way for MemoryStreamingChannel

impl StreamingInput for MemoryStreamingChannel

fn send_chunk<'life0, 'async_trait>( &'life0 self, chunk: StreamChunk, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a chunk to the guest

fn send_bytes<'life0, 'life1, 'async_trait>( &'life0 self, data: &'life1 [u8], is_final: bool, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send raw bytes to the guest

fn send_stream<'life0, 'life1, 'async_trait, S>( &'life0 self, stream: &'life1 mut S, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where S: Stream<Item = Result<StreamChunk>> + Unpin + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a stream of chunks to the guest

impl StreamingOutput for MemoryStreamingChannel

fn receive_chunk<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<StreamChunk>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receive a chunk from the guest

fn receive_bytes<'life0, 'async_trait>( &'life0 self, max_size: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receive raw bytes from the guest

fn receive_stream( &self, ) -> Pin<Box<dyn Stream<Item = Result<StreamChunk>> + Send>>

Receive a stream of chunks from the guest