Struct ReplaySubject

pub struct ReplaySubject<T> { /* private fields */ }

Implementations

impl<T> ReplaySubject<T>

pub fn new() -> Self

pub fn buffer_len(&self) -> usize

pub fn buffer_size(size: usize) -> Self

Trait Implementations

impl<T> Drop for ReplaySubject<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> Subject for ReplaySubject<T>

type Item = T

fn subscribe(&mut self) -> Observable<Self::Item>

fn close(&mut self)

fn next(&mut self, value: Self::Item)

fn for_each_subscription<F: FnMut(&mut Rc<RefCell<Controller<Event<Self::Item>>>>)>( &mut self, f: F, )