Subscription.js

  1. import { Observer } from './Observer';
  2. import { noop } from './utilities';
  4. /**
  5.  * @param {Function} callback
  6.  * @param {{next: Function, error: Function, complete: Function}} observer
  7.  */
  8. export class Subscription {
  9.   constructor (callback = noop, observer = {}) {
  10.     this.observer = new Observer(observer);
  11.     
  12.     this.observer.use(callback);
  13.   }
  14.   
  15.   static createSimple (observer) {
  16.     return new Subscription(noop, observer);
  17.   }
  19.   /**
  20.    * Unsubscribe to the event stream
  21.    *
  22.    * @returns {void}
  23.    */
  24.   unsubscribe () {
  25.     this.observer.cleanup();
  26.   }
  28.   /**
  29.    *
  30.    * @returns {boolean}
  31.    */
  32.   get isComplete () {
  33.     return this.observer.isComplete;
  34.   }
  35.   
  36.   get onNext () {
  37.     return this.observer.onNext;
  38.   }
  39.   
  40.   get onError () {
  41.     return this.observer.onError;
  42.   }
  43.   
  44.   get onComplete () {
  45.     return this.observer.onComplete;
  46.   }
  47. }