stopped-notifications.ts

import { config } from "rxjs";

config.onStoppedNotification = (notification) => {
  switch (notification.kind) {
    case "E":
      const error: any = new Error(
        "Cannot notify stopped observer"
      );
      error.notification = notification;
      throw error;
    default:
      return;
  }
};