Struct ErasedObservable 

pub struct ErasedObservable<Out, OutError>
where
    Out: Signal,
    OutError: Signal,
{ /* private fields */ }

Implementations

impl<Out, OutError> ErasedObservable<Out, OutError>

where Out: 'static + Signal, OutError: 'static + Signal,

pub fn new<O>(observable: O) -> Self

where O: 'static + Observable<Out = Out, OutError = OutError> + Send + Sync,

Trait Implementations

impl<Out, OutError> Clone for ErasedObservable<Out, OutError>

where Out: 'static + Signal, OutError: 'static + Signal,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Out, OutError> Observable for ErasedObservable<Out, OutError>

where Out: Signal, OutError: Signal,

type Subscription<Destination> = SubscriptionData where Destination: 'static + Subscriber<In = Self::Out, InError = Self::OutError>

The subscription produced by this Observable. As this is the only kind of subscription that is handled directly by users, only here are subscriptions required to implement Drop to ensure resources are released when the subscription is dropped.

fn subscribe<Destination>( &mut self, destination: Destination, ) -> Self::Subscription<Destination::Upgraded>

where Destination: 'static + UpgradeableObserver<In = Self::Out, InError = Self::OutError> + Send + Sync,

Create a Subscription for this Observable. This action allocates resources to execute the behavior this Observable defines, essentially creating an instance of it.

impl<Out, OutError> ObservableOutput for ErasedObservable<Out, OutError>

where Out: Signal, OutError: Signal,

type Out = Out

type OutError = OutError

impl<Out, OutError> WithPrimaryCategory for ErasedObservable<Out, OutError>

where Out: Signal, OutError: Signal,

type PrimaryCategory = PrimaryCategoryObservable