pub struct InactiveReceiver<T> { /* private fields */ }
Expand description

An inactive receiver.

An inactive receiver is a receiver that is unable to receive messages. It’s only useful for keeping a channel open even when no associated active receivers exist.

Implementations§

source§

impl<T> InactiveReceiver<T>

source

pub fn activate(self) -> Receiver<T>

Convert to an activate Receiver.

Consumes self. Use InactiveReceiver::activate_cloned if you want to keep self.

Examples
use async_broadcast::{broadcast, TrySendError};

let (s, r) = broadcast(1);
let inactive = r.deactivate();
assert_eq!(s.try_broadcast(10), Err(TrySendError::Inactive(10)));

let mut r = inactive.activate();
assert_eq!(s.try_broadcast(10), Ok(None));
assert_eq!(r.try_recv(), Ok(10));
source

pub fn activate_cloned(&self) -> Receiver<T>

Create an activate Receiver for the associated channel.

Examples
use async_broadcast::{broadcast, TrySendError};

let (s, r) = broadcast(1);
let inactive = r.deactivate();
assert_eq!(s.try_broadcast(10), Err(TrySendError::Inactive(10)));

let mut r = inactive.activate_cloned();
assert_eq!(s.try_broadcast(10), Ok(None));
assert_eq!(r.try_recv(), Ok(10));
source

pub fn capacity(&self) -> usize

Returns the channel capacity.

See Receiver::capacity documentation for examples.

source

pub fn set_capacity(&mut self, new_cap: usize)

Set the channel capacity.

There are times when you need to change the channel’s capacity after creating it. If the new_cap is less than the number of messages in the channel, the oldest messages will be dropped to shrink the channel.

See Receiver::set_capacity documentation for examples.

source

pub fn overflow(&self) -> bool

If overflow mode is enabled on this channel.

See Receiver::overflow documentation for examples.

source

pub fn set_overflow(&mut self, overflow: bool)

Set overflow mode on the channel.

When overflow mode is set, broadcasting to the channel will succeed even if the channel is full. It achieves that by removing the oldest message from the channel.

See Receiver::set_overflow documentation for examples.

source

pub fn await_active(&self) -> bool

If sender will wait for active receivers.

If set to false, Send will resolve immediately with a SendError. Defaults to true.

Examples
use async_broadcast::broadcast;

let (_, r) = broadcast::<i32>(5);
let r = r.deactivate();
assert!(r.await_active());
source

pub fn set_await_active(&mut self, await_active: bool)

Specify if sender will wait for active receivers.

If set to false, Send will resolve immediately with a SendError. Defaults to true.

Examples
use async_broadcast::broadcast;

let (s, r) = broadcast::<i32>(2);
s.broadcast(1).await.unwrap();

let mut r = r.deactivate();
r.set_await_active(false);
assert!(s.broadcast(2).await.is_err());
source

pub fn close(&self) -> bool

Closes the channel.

Returns true if this call has closed the channel and it was not closed already.

The remaining messages can still be received.

See Receiver::close documentation for examples.

source

pub fn is_closed(&self) -> bool

Returns true if the channel is closed.

See Receiver::is_closed documentation for examples.

source

pub fn is_empty(&self) -> bool

Returns true if the channel is empty.

See Receiver::is_empty documentation for examples.

source

pub fn is_full(&self) -> bool

Returns true if the channel is full.

See Receiver::is_full documentation for examples.

source

pub fn len(&self) -> usize

Returns the number of messages in the channel.

See Receiver::len documentation for examples.

source

pub fn receiver_count(&self) -> usize

Returns the number of receivers for the channel.

This does not include inactive receivers. Use InactiveReceiver::inactive_receiver_count if you’re interested in that.

Examples
use async_broadcast::broadcast;

let (s, r) = broadcast::<()>(1);
assert_eq!(s.receiver_count(), 1);
let r = r.deactivate();
assert_eq!(s.receiver_count(), 0);

let r2 = r.activate_cloned();
assert_eq!(r.receiver_count(), 1);
assert_eq!(r.inactive_receiver_count(), 1);
source

pub fn inactive_receiver_count(&self) -> usize

Returns the number of inactive receivers for the channel.

Examples
use async_broadcast::broadcast;

let (s, r) = broadcast::<()>(1);
assert_eq!(s.receiver_count(), 1);
let r = r.deactivate();
assert_eq!(s.receiver_count(), 0);

let r2 = r.activate_cloned();
assert_eq!(r.receiver_count(), 1);
assert_eq!(r.inactive_receiver_count(), 1);
source

pub fn sender_count(&self) -> usize

Returns the number of senders for the channel.

See Receiver::sender_count documentation for examples.

Trait Implementations§

source§

impl<T> Clone for InactiveReceiver<T>

source§

fn clone(&self) -> Self

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl<T: Debug> Debug for InactiveReceiver<T>

source§

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

Formats the value using the given formatter. Read more
source§

impl<T> Drop for InactiveReceiver<T>

source§

fn drop(&mut self)

Executes the destructor for this type. Read more

Auto Trait Implementations§

§

impl<T> RefUnwindSafe for InactiveReceiver<T>

§

impl<T> Send for InactiveReceiver<T>
where T: Send + Sync,

§

impl<T> Sync for InactiveReceiver<T>
where T: Send + Sync,

§

impl<T> Unpin for InactiveReceiver<T>

§

impl<T> UnwindSafe for InactiveReceiver<T>

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.