As we mentioned already, pipeable operators are here, and you can find them by importing the respective operators from the rxjs/operators directory, like so:
import { map } from "rxjs/operators/map";
import { filter } from "rxjs/operators/filter";
To use it, we are now relying on the pipe() operator that we use as the parent operator, if you will. Using the preceding operators will therefore look like this:
import { map } from "rxjs/operators/map";
import { filter } from "rxjs/operators";
import { of } from "rxjs/observable/of";
import { Observable } from "rxjs/Observable";
let stream = of(1,2);
stream.pipe(
map(x => x + 1),
filter(x => x > 1)
)
.subscribe(x => console.log("piped", x)); // emits 2 and 3