pub trait SharedObservable: Observable {
type Unsub: SubscriptionLike + 'static;
// Required method
fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>(
self,
subscriber: Subscriber<O, SharedSubscription>,
) -> Self::Unsub;
// Provided method
fn into_shared(self) -> Shared<Self>
where Self: Sized { ... }
}Required Associated Types§
type Unsub: SubscriptionLike + 'static
Required Methods§
fn actual_subscribe<O: Observer<Item = Self::Item, Err = Self::Err> + Sync + Send + 'static>( self, subscriber: Subscriber<O, SharedSubscription>, ) -> Self::Unsub
Provided Methods§
Convert to a thread-safe mode.
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.