Enum StreamingChannel2WayImpl 

pub enum StreamingChannel2WayImpl {
    Memory(MemoryStreamingChannel),
    File(FileStreamingChannel),
}

Concrete implementation for dynamic dispatch

Variants

Memory(MemoryStreamingChannel)

File(FileStreamingChannel)

Trait Implementations

impl Clone for StreamingChannel2WayImpl

fn clone(&self) -> StreamingChannel2WayImpl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StreamingChannel for StreamingChannel2WayImpl

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 StreamingChannel2WayImpl

impl StreamingInput for StreamingChannel2WayImpl

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 StreamingChannel2WayImpl

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