Struct ServerStreamDriver 

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

Typed stream driver sharing a single caller-thread server connection.

Trait Implementations

impl<T: SyncTransport, C: Codec> StreamDriver for ServerStreamDriver<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: &Status, trailers: &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)