Skip to main content

BroadcastBuilder

par_stream

Struct BroadcastBuilder 

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

The build type returned from broadcast().

It is used to register new broadcast receivers. Each receiver consumes copies of items of the stream. The builder is finished by guard.build() so that registered receivers can start consuming data. Otherwise, the receivers take empty input.

Implementations§

Source§

impl<T> BroadcastBuilder<T>
where T: 'static + Send + Clone,

Source

pub fn new<B, St>( stream: St, buf_size: B, send_all: bool, ) -> BroadcastBuilder<T>
where St: 'static + Send + Stream<Item = T>, B: Into<BufSize>,

Source

pub fn register(&mut self) -> BroadcastStream<T>

Creates a new receiver.

Source

pub fn build(self)

Finish the builder to start broadcasting.

Trait Implementations§

Source§

impl<T: Debug> Debug for BroadcastBuilder<T>

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<T> !RefUnwindSafe for BroadcastBuilder<T>

§

impl<T> !UnwindSafe for BroadcastBuilder<T>

§

impl<T> Freeze for BroadcastBuilder<T>

§

impl<T> Send for BroadcastBuilder<T>
where T: Send,

§

impl<T> Sync for BroadcastBuilder<T>
where T: Send,

§

impl<T> Unpin for BroadcastBuilder<T>

§

impl<T> UnsafeUnpin for BroadcastBuilder<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> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

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

Source§

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>,

Source§

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.