[Angular] Upgrading to RxJS v6

This is just a learning blog post, check out the talk.

1. Custom pipeable operators:

Custom pipeable operator is just a high order function which return an observable.

const pow = (p: number) => (source: Observable<number>) => source.pipe(map(n => n ** p ))

source$.pipe(

  filter(x => x > ),

  pow()

).subscribe(x => console.log(x))

2. Error handling: Throw error asynclly:

badSource$.subscribe(nextFn. handlerError, completeFn)

3. Simpler import:

import {interval, of} from 'rxjs';

import {filter, mergeMap, scan} from 'rxjs/operators';

interval().pipe(

    filter(x => x %  === ),

    mergeMap(x => of(x + , x + , x + m)),

    scan((s, x) => s +x, )

).subscribe(x => console.log(x));

4. New operator: throwIfEmpty

const mustClick$ = buttonClick$.pipe(

    takeUntil(this.viewResize$),

    throwIfEmpty(

        () => new Error('user did not click before resize')

    ),

);

5. If you want to migration to rxjs v6:

6. Update you code automatically:

巴特西

[Angular] Upgrading to RxJS v6

最新文章

热门文章