Struct StreamController

pub struct StreamController<'a, Item>
where
    Item: Clone + Send + Sync + 'a,
{ /* private fields */ }

Implementations

impl<'a, Item> StreamController<'a, Item>

where Item: Clone + Send + Sync,

pub fn new(subscriber: Observer<'_, Item>) -> StreamController<'_, Item>

pub fn set_on_finalize<F>(&self, f: F)

where F: Fn() + Send + Sync + 'a,

pub fn new_observer<XItem, Next, Error, Complete>( &self, next: Next, error: Error, complete: Complete, ) -> Observer<'a, XItem>

where XItem: Clone + Send + Sync + 'a, Next: Fn(i32, XItem) + Send + Sync + 'a, Error: Fn(i32, RxError) + Send + Sync + 'a, Complete: Fn(i32) + Send + Sync + 'a,

pub fn sink_next(&self, x: Item)

pub fn sink_error(&self, e: RxError)

pub fn sink_complete(&self, serial: &i32)

pub fn sink_complete_force(&self)

pub fn upstream_abort_observe(&self, serial: &i32)

pub fn finalize(&self)

pub fn is_subscribed(&self) -> bool

Trait Implementations

impl<'a, Item> Clone for StreamController<'a, Item>

where Item: Clone + Send + Sync + 'a + Clone,

fn clone(&self) -> StreamController<'a, Item>

Returns a duplicate of the value.

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

Performs copy-assignment from source.