Some words of advice, before using this framework:
Clarification: higher order observables => observables which emit observables
- Flattening operators:
- switch -> Observable[Observable] => Observable -> switches to the latest Observable upon its firing AND unsubscribes from the previous one
- mergeAll(numOfObs:number) -> merges all of the inner observables concurrently (duh) -> the param "numOfObs" limits the max number of observables to which one can subscribe concurrently. If some of the subscribed ones complete, then this thing will subscribe to newly created ones - otherwise nothing will happen upon spawning new observables
- contcatAll == mergeAll(1) -> subscribe to at most 1 observable, gather the ones created afterwards and upon the completion of the subscribed one, subscribe automatically to the next one