Jul 4, 2024
npm install rxjs
.index.js
file.const { Observable, of } = require('rxjs');
.const observable = new Observable(subscriber => { subscriber.next(users); });
next
, error
, and complete
methods.observable.subscribe(observer);
pipe
to manipulate and transform data through various operators like map
, filter
, and reduce
.pluck
to extract array of users from the object.
const { pluck } = require('rxjs/operators');
observable.pipe(
pluck('data')
)
.subscribe(observer);
filter
to keep only active users.
const { filter } = require('rxjs/operators');
observable.pipe(
pluck('data'),
filter(user => user.status === 'active')
)
.subscribe(observer);
reduce
to calculate average age and possibly throw an error if below 18.
const { reduce } = require('rxjs/operators');
observable.pipe(
pluck('data'),
filter(user => user.status === 'active'),
reduce((acc, user) => acc + user.age, 0)
)
.subscribe(observer);
complete
method.