rx_core_common 0.2.2

rx_core's core traits and implementations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use crate::{ObserverUpgradesToSelf, RxObserver, SubscriptionWithTeardown};

/// # [Subscriber]
///
/// A [Subscriber] is an [Observer] that is also a [SubscriptionLike], so it
/// can clean itself up upon unsubscribe.
///
/// ## For Implementations
///
/// A struct implementing [Subscriber] should have all their fields as private,
/// as users will never directly interact with a [Subscriber].
///
/// ### Inlining
///
/// A subscribers [Observer] functions like `next`, `error` and `complete`
/// that just simply forward the signal to its destination should always
/// be `#[inline]`.
pub trait Subscriber:
	RxObserver + ObserverUpgradesToSelf + SubscriptionWithTeardown + Send + Sync
{
}

impl<T> Subscriber for T where
	T: RxObserver + ObserverUpgradesToSelf + SubscriptionWithTeardown + Send + Sync
{
}