Struct ReactiveTest 

pub struct ReactiveTest;

The factories of recorded notifications and subscriptions, and the default times of TestScheduler::start (ReactiveTest).

Implementations

impl ReactiveTest

pub const CREATED: i64 = 100

The default time the sequence is created at (Created).

pub const SUBSCRIBED: i64 = 200

The default time the observer subscribes at (Subscribed).

pub const DISPOSED: i64 = 1000

The default time the subscription is disposed at (Disposed).

pub fn on_next<T>(ticks: i64, value: T) -> Recorded<Notification<T>>

A value at ticks (OnNext<T>(long, T)).

pub fn on_next_where<T>( ticks: i64, predicate: impl Fn(&T) -> bool + 'static, ) -> Recorded<Expected<T>>

A value at ticks for which predicate is true (OnNext<T>(long, Func<T, bool>)).

pub fn on_completed<T>(ticks: i64) -> Recorded<Notification<T>>

The end of the sequence at ticks (OnCompleted<T>(long)).

pub fn on_error<T>( ticks: i64, error: ObservableError, ) -> Recorded<Notification<T>>

An error at ticks (OnError<T>(long, Exception)).

pub fn on_error_where<T>( ticks: i64, predicate: impl Fn(&ObservableError) -> bool + 'static, ) -> Recorded<Expected<T>>

An error at ticks for which predicate is true (OnError<T>(long, Func<Exception, bool>)).

pub fn subscribe(start: i64, end: i64) -> Subscription

A subscription from start to end (Subscribe(long, long)).

pub fn subscribe_from(start: i64) -> Subscription

A subscription from start that has not been disposed (Subscribe(long)).