Struct ChannelStreamDriver 

pub struct ChannelStreamDriver<T: SyncTransport, C: Codec> { /* private fields */ }

Typed streaming driver over one shared caller-thread channel connection.

Trait Implementations

impl<T: SyncTransport, C: Codec> Drop for ChannelStreamDriver<T, C>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<T: SyncTransport, C: Codec> StreamDriver for ChannelStreamDriver<T, C>

where C::EncodeItem: Sized,

type Send = <C as Codec>::EncodeItem

type Receive = <C as Codec>::DecodeItem

fn send(&mut self, message: &Self::Send) -> Result<(), StreamError>

Attempts to commit one outgoing message.

fn half_close(&mut self) -> Result<(), StreamError>

Attempts to half-close outgoing messages.

fn try_recv_next(&mut self) -> Result<Option<Self::Receive>, StreamError>

Receives a message, validated EOF, or a pending/terminal error.

fn wait_ready(&mut self) -> Result<(), StreamError>

Waits for readiness needed by the last pending operation.

fn finish(&mut self, _: &Status, _: &Metadata) -> Result<(), StreamError>

Attempts server completion, including non-OK trailers-only responses.

fn initial_metadata(&self) -> Option<&Metadata>

fn trailing_metadata(&self) -> Option<&Metadata>

fn cancel(&mut self)