Trait ChannelCapability 

pub trait ChannelCapability: Send + Sync {
    type Channel: Send;
    type StrongWriter: Send + Unpin;
    type WeakWriter: Send + Unpin;
    type StrongReader: Send + Unpin;
    type WeakReader: Send + Unpin;
    type Error: Into<GuestError>;

    // Required methods
    fn create(
        &self,
        size: GuestUint,
        backpressure: ChannelBackpressure,
    ) -> Result<Self::Channel, Self::Error>;
    fn delete(&self, channel: Self::Channel) -> Result<(), Self::Error>;
    fn drain(&self, channel: &Self::Channel) -> Result<(), Self::Error>;
    fn downgrade_writer(
        &self,
        writer: Self::StrongWriter,
    ) -> Result<Self::WeakWriter, Self::Error>;
    fn downgrade_reader(
        &self,
        writer: Self::StrongReader,
    ) -> Result<Self::WeakReader, Self::Error>;
}

The capabilities that any subsystem implementation needs to provide

Required Associated Types

type Channel: Send

type StrongWriter: Send + Unpin

type WeakWriter: Send + Unpin

type StrongReader: Send + Unpin

type WeakReader: Send + Unpin

type Error: Into<GuestError>

Required Methods

fn create( &self, size: GuestUint, backpressure: ChannelBackpressure, ) -> Result<Self::Channel, Self::Error>

Create a new channel for transporting bytes.

fn delete(&self, channel: Self::Channel) -> Result<(), Self::Error>

Delete this channel

fn drain(&self, channel: &Self::Channel) -> Result<(), Self::Error>

Terminate this channel whilst allowing unfinished reads/writes to continue

fn downgrade_writer( &self, writer: Self::StrongWriter, ) -> Result<Self::WeakWriter, Self::Error>

Downgrade this strong writer to a weak variant

fn downgrade_reader( &self, writer: Self::StrongReader, ) -> Result<Self::WeakReader, Self::Error>

Downgrade this strong writer to a weak variant

Implementations on Foreign Types

impl<T> ChannelCapability for Arc<T>

where T: ChannelCapability + Send + Sync,

type Channel = <T as ChannelCapability>::Channel

type StrongWriter = <T as ChannelCapability>::StrongWriter

type WeakWriter = <T as ChannelCapability>::WeakWriter

type StrongReader = <T as ChannelCapability>::StrongReader

type WeakReader = <T as ChannelCapability>::WeakReader

type Error = <T as ChannelCapability>::Error

fn create( &self, size: GuestUint, backpressure: ChannelBackpressure, ) -> Result<Self::Channel, Self::Error>

fn delete(&self, channel: Self::Channel) -> Result<(), Self::Error>

fn drain(&self, channel: &Self::Channel) -> Result<(), Self::Error>

fn downgrade_writer( &self, writer: Self::StrongWriter, ) -> Result<Self::WeakWriter, Self::Error>

fn downgrade_reader( &self, reader: Self::StrongReader, ) -> Result<Self::WeakReader, Self::Error>

Implementors