xstream-extra-factories

Extra generic factories for xstream

forever

Creates a memory stream of a single item that never completes.
Like xs.of(item) but does not send a completion event and always
remembers.

fromAsyncIterable

Creates a stream from an async iterable (such as an async generator function: async function* name()).

fromCancellableDualCallback

Creates a stream from a "watch" function that expects a success callback, an error callback,
any number of arguments following that, then returns an ID for cancellation. An example would
be navigator.geolocation.watchPosition().

fromDualCallback

Creates a stream from a function that expects a success callback, an error callback, then any
number of arguments following that. An example would be navigator.geolocation.getPosition().

fromNodeCallback

Creates a stream from a Node-style callback. A Node-style callback
function takes any number of arguments and then lastly a callback of the
form (error: any, value: T) => void.