Skip to main content
class Observable
implements ObservableLike<Value>
import { Observable } from "https://deno.land/x/observable@v0.1-alpha/mod.ts";

An Observable represents a sequence of values which may be observed.

Constructors

new
Observable(subscriber: SubscriberFunction<Value>)

Type Parameters

optional
Value = unknown

Properties

private
_subscriber: SubscriberFunction<Value>

Methods

Subscribes to the sequence with an observer

subscribe(
onNext: (value: Value) => void,
onError?: (error: unknown) => void,
onComplete?: () => void,
): SubscriptionLike

Subscribes to the sequence with callbacks

Static Methods

from<Value = unknown>(observable: ObservableLike<Value>): Observable<Value>

Converts an observable Observable

from<Value = unknown>(iterable: Iterable<Value>): Observable<Value>

Converts an iterable to an Observable

from<Value = unknown>(iterable: AsyncIterable<Value>): Observable<Value>

Converts an async iterable to an Observable

of<Value = unknown>(...items: Value[]): Observable<Value>

Converts arguments to an Observable