node_modules/@analytics/core/lib/analytics.es.js
/**
   * Interoperability point for observable/reactive libraries.
   * @returns {observable} A minimal observable of state changes.
   * For more information, see the observable proposal:
   * https://github.com/tc39/proposal-observable
   */
Interoperability point for observable/reactive libraries.
@returns {observable} A minimal observable of state changes.
Interoperability point for observable / reactive libraries . @returns { observable } A minimal observable of state changes .
function observable() {
    var outerSubscribe = subscribe;
    return defineProperty({
      subscribe: function subscribe(observer) {
        if (_typeof_1(observer) !== 'object') {
          throw new TypeError('Observer != obj');
        }
        function observeState() {
          if (observer.next) {
            observer.next(getState());
          }
        }
        observeState();
        var unsubscribe = outerSubscribe(observeState);
        return {
          unsubscribe: unsubscribe
        };
      }
    }, $$observable, function () {
      return this;
    });
  } 
function observable ( ) { var outerSubscribe = subscribe ; return defineProperty ( { subscribe : function subscribe ( observer ) { if ( _typeof_1 ( observer ) !== 'object' ) { throw new TypeError ( 'Observer != obj' ) ; } function observeState ( ) { if ( observer . next ) { observer . next ( getState ( ) ) ; } } observeState ( ) ; var unsubscribe = outerSubscribe ( observeState ) ; return { unsubscribe : unsubscribe } ; } } , $$observable , function ( ) { return this ; } ) ; }
Interoperability point for observable/reactive libraries.
Interoperability point for observable / reactive libraries .
/*
       * The minimal observable subscription method.
       * @param {Object} observer Any object that can be used as an observer.
       * The observer object should have a `next` method.
       * @returns {subscription} An object with an `unsubscribe` method that can
       * be used to unsubscribe the observable from the store, and prevent further
       * emission of values from the observable.
       */ // When a store is created, an "INIT" action is dispatched so that every