Interview Questions and Answers

Example:

const modifiedObservable = observable.pipe(map(value => value.toUpperCase()));

Example:

const modifiedObservable = observable.pipe(map(value => value * 2));

Example:

const modifiedObservable = observable.pipe(mergeMap(value => of(value, value * 2)));

Example:

const filteredObservable = observable.pipe(filter(value => value > 5));

Example:

import { map, filter } from 'rxjs/operators'; const modifiedObservable = observable.pipe(map(value => value * 2), filter(value => value > 5));

Example:

const switchedObservable = observable.pipe(switchMap(value => of(value, value * 2)));

Example:

const subject = new Subject(); subject.next('First value'); subject.subscribe(value => console.log(value));

Example:

const concatenatedObservable = observable.pipe(concatMap(value => of(value, value * 2)));

Example:

const errorHandledObservable = observable.pipe(catchError(err => of('Error handled:', err)));

Example:

const zippedObservable = zip(observable1, observable2, (value1, value2) => value1 + value2);

Example:

const bufferedObservable = observable.pipe(bufferTime(1000));

Example:

const throttledObservable = inputObservable.pipe(throttleTime(300));

Example:

const combinedObservable = combineLatest(observable1, observable2, (value1, value2) => value1 + value2);

Example:

const deferredObservable = defer(() => of('Deferred value'));