medium-rxjs-operators-pipeable

medium-rxjs-operators-pipeable.js

import { Observable } from 'rxjs';
import { first } from 'rxjs/operators';

// Create a Observable which emits 2 values
const observable = new Observable(subscriber => {
  subscriber.next('First Message');
  subscriber.next('Second Message');
});

// "first()" is a pipeable operator that only returns the observable with the first value.
observable
  .pipe(first())
  .subscribe(data => console.log(data));

// CONSOLE OUTPUT ------------------
// > First Message