With this function you can quickly create an observable based on a recipe provided as an argument.
Source | Behaviour |
Iterable (i.e. an Array) | Creates an observable that sends items as messages as soon as possible and then send |
AsyncIterable (i.e. Asynchronous Generator Function) | Creates an observable that sends out each message as it is yielded from the source and sends |
Any other | Creates an observable that emits the argument as a message and then shuts down with |