Struct StreamProducer 

pub struct StreamProducer<A, S> { /* private fields */ }

A producer for promised streams.

Implementations

impl<A, S> StreamProducer<A, S>

pub async fn send(&self, addr: A, conn: S) -> Result<(), SendError<(A, S)>>

Sends a promised stream into the producer.

If the producer is full, this method waits until there is space for a stream.

If the producer is closed, this method returns an error.

pub fn try_send(&self, addr: A, conn: S) -> Result<(), TrySendError<(A, S)>>

Attempts to send a promised stream into the producer.

If the producer is full or closed, this method returns an error.

pub fn is_empty(&self) -> bool

Returns true if the producer is empty.

pub fn len(&self) -> usize

Returns the number of promised streams in the producer.

pub fn is_full(&self) -> bool

Returns true if the producer is full.

pub fn is_closed(&self) -> bool

Returns true if the producer is closed.

pub fn close(&self) -> bool

Closes the producer. Returns true if the producer was closed by this call.

Trait Implementations

impl<A, S> Clone for StreamProducer<A, S>

fn clone(&self) -> StreamProducer<A, S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A, S> Debug for StreamProducer<A, S>

where A: Debug, S: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.