AsyncSubject Example

async-subject.example.ts

import {AsyncSubject} from 'rxjs/internal/AsyncSubject';

let subject = new AsyncSubject;

let i = 0;
const handle = setInterval(() => {
  subject.next(i);
  if (++i > 3) {
    subject.complete();
    clearInterval(handle);
  }
}, 500);

const subscription = subject.subscribe((x: number) => {
  console.log(`Next: ${String(x)}`);
}, (error: Error) => {
  console.log(`Error: ${error}`);
}, () => {
  console.log('Completed');
});