You can use withLatestFrom. . source.withLatestFrom(checkboxes, (data, checkbox) => ({data, checkbox})) .filter(({data, checkbox}) => …) Here, checkboxes is an observable representing a list of checkbox inputs. source is an observable representing a stream of events coming from the server. In the filter function you can check if the data is valid compared to the checkbox … Read more
No, they are absolutely not the same thing. Reactive Extensions is a library for creating and composing observable streams of data or events (which are actually quite similar). It basically knows nothing about client-server connections or other things. It is focused solely on Observables and is capable of wrapping any collection, stream, event, async method, … Read more
Its definitly not needed to import all operators at once! You just imported fromEvent wrong. You could do it like this: import {Observable} from ‘rxjs/Observable’; import ‘rxjs/add/observable/fromEvent’; EDIT: In addititon to what I already wrote: tree-shaking with the AoT-Compiler of angular removes unused code, based on what you import. If you just import some objects … Read more
It turns out the answer is quite simple: the operator is called mergeMap in this version of rxjs EDIT: Furthermore, you might have to use import ‘rxjs/add/operator/mergeMap’.