Struct PacketProducer

pub struct PacketProducer<A, T> { /* private fields */ }

A producer for packets.

Implementations

impl<A, T> PacketProducer<A, T>

pub async fn send( &self, packet: Packet<A, T>, ) -> Result<(), SendError<Packet<A, T>>>

Sends a packet into the producer.

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

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

pub fn try_send( &self, packet: Packet<A, T>, ) -> Result<(), TrySendError<Packet<A, T>>>

Attempts to send a packet into the producer.

If the channel 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 packets 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, T> Clone for PacketProducer<A, T>

where A: Clone, T: Clone,

fn clone(&self) -> PacketProducer<A, T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A, T> Debug for PacketProducer<A, T>

where A: Debug, T: Debug,

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

Formats the value using the given formatter.