Struct StreamInput 

pub struct StreamInput<T> { /* private fields */ }

Implementations

impl<T> StreamInput<T>

pub fn into_receiver(self) -> Receiver<StreamItem<T>>

pub fn try_recv(&mut self) -> Result<StreamItem<T>, TryRecvError>

pub async fn recv(&mut self) -> Option<StreamItem<T>>

pub fn close(&mut self)

Trait Implementations

impl<T> EndpointSet for StreamInput<T>

where T: Send + 'static,

fn transferred(&self) -> bool

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

impl<T> InputEndpoint for StreamInput<T>

where T: Send + 'static,

type Item = T

fn transferred(&self) -> bool

impl<T> WireEndpoints for StreamInput<T>

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

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

fn empty() -> Option<Self>