Struct StreamOutput 

pub struct StreamOutput<T, E = Error> { /* private fields */ }

Implementations

impl<T, E> StreamOutput<T, E>

where E: From<Error>,

pub fn is_closed(&self) -> bool

pub async fn reserve(&self, bytes: usize) -> Result<StreamPermit<'_, T, E>, E>

impl<T, E> StreamOutput<T, E>

where T: MemorySize, E: From<Error>,

pub async fn send_item(&self, item: StreamItem<T>) -> Result<(), E>

pub async fn send_with( &self, bytes: usize, make: impl FnOnce() -> Result<T, E>, ) -> Result<(), E>

impl<T, E> StreamOutput<T, E>

where T: MemorySize + Send + Sync + 'static, E: From<Error>,

pub async fn send_owned(&self, value: Response<T>) -> Result<(), E>

impl<T, E> StreamOutput<T, E>

where T: Message + MemorySize, E: From<Error>,

pub async fn decode(&self, encoded: &[u8]) -> Result<(), E>

Trait Implementations

impl<T, E> Clone for StreamOutput<T, E>

fn clone(&self) -> StreamOutput<T, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, E> EndpointSet for StreamOutput<T, E>

where T: Message + MemorySize + Send + 'static, E: 'static,

fn bind_wire( limits: WireStreamLimits, ) -> Result<(StreamOutput<T, E>, WireStreams), ServingError>

fn transferred(&self) -> bool

fn item_types() -> (Option<TypeId>, Option<TypeId>)

fn empty() -> Option<Self>

impl<T, E> OutputEndpoint for StreamOutput<T, E>

where T: Message + MemorySize + Send + 'static, E: 'static,

type Item = T

fn bind_wire( limits: WireStreamLimits, ) -> Result<(StreamOutput<T, E>, WireStreams), ServingError>

fn transferred(&self) -> bool

impl<T, E> WireEndpoints for StreamOutput<T, E>

where T: Message + MemorySize + Send + 'static, E: 'static,

fn bind( limits: WireStreamLimits, ) -> Result<(StreamOutput<T, E>, WireStreams), ServingError>

fn empty() -> Option<Self>