Symbol indicating the end of a stream. Used with external.

Utility function to create new observables from external sources. Returns an object with two values: the new observable, and a next function which will emit a value to observable when called. Calling next with EOF will indicate there are no more values to emit.

Creates an observable from an asynchronous function. The observable emits exactly one value when once the function returns.

Create a ReadableStream<Uint8Array> from from a Deno.Reader.

Creates an observable from an EventTarget. Each event is turned into an item for the observable.

Creates an observable from a generator that takes no arguments.

Create a ReadableStream from any kind of iterable.

Creates an observable from a function that gets passed the observable's next() function.

Creates an observable from a promise, that emits exactly one value when the promise resolves.

Creates an observable that will forever emit null every ms milliseconds.

Creates an observable that emits a set of values.

An alias for just.

Creates an observable that emits numbers from start to end.

Creates an observable that forever emits the same value.