Creates a new observable using the given subscriber function.
The subscriber function.
Subscribes the given observer to this object.
Object which can be used to unsubscribe the observer.
Constructs a new observer using the given callback functions and subscribes it to this object.
Receives the next value in the sequence.
Optional
onError: (error: Error) => voidReceives the sequence error.
Optional
onComplete: () => voidReceives a completion notification.
Object which can be used to unsubscribe the observer.
Optional
complete: () => voidStatic
fromConverts any observable object or iterable to an Observable.
The observable or iterable to convert.
The created observable.
Static
ofConverts items to an Observable.
The items to convert.
The created observable.
Observable implementation.