actorx/create
Creation operators for ActorX
These functions create new Observable sequences from various sources:
- single: Single value then complete
- empty: Complete immediately
- never: Never emit or complete
- fail: Error immediately
- from_list: Emit all items from a list
- defer: Factory function called on each subscription
Values
pub fn create(
subscribe: fn(types.Observer(a)) -> types.Disposable,
) -> types.Observable(a)Create an observable from a subscribe function.
pub fn defer(
factory: fn() -> types.Observable(a),
) -> types.Observable(a)Returns an observable that invokes the factory function whenever a new observer subscribes.
pub fn empty() -> types.Observable(a)Returns an observable sequence with no elements that completes immediately.
pub fn fail(error: String) -> types.Observable(a)Returns an observable sequence that errors immediately.
pub fn from_list(items: List(a)) -> types.Observable(a)Returns an observable sequence from a list of values. Emits each value in order, then completes.
pub fn never() -> types.Observable(a)Returns an observable sequence that never emits and never completes.
pub fn single(value: a) -> types.Observable(a)Returns an observable sequence containing a single element.