{"version":3,"sources":["node_modules\\babel-polyfill\\node_modules\\core-js\\modules\\es7.observable.js"],"names":["$export","require","global","core","microtask","OBSERVABLE","aFunction","anObject","anInstance","redefineAll","hide","forOf","RETURN","getMethod","fn","undefined","cleanupSubscription","subscription","cleanup","_c","subscriptionClosed","_o","closeSubscription","Subscription","observer","subscriber","SubscriptionObserver","unsubscribe","e","error","prototype","_s","next","value","m","call","complete","$Observable","Observable","_f","subscribe","forEach","that","Promise","resolve","reject","from","x","C","method","observable","constructor","done","it","of","i","l","arguments","length","items","Array","G"],"mappings":"AAAA;;AAEA,GAAIA,SAAcC,QAAQ,WAAR,CAAlB;AACIC,OAAcD,QAAQ,WAAR,CADlB;AAEIE,KAAcF,QAAQ,SAAR,CAFlB;AAGIG,UAAcH,QAAQ,cAAR,GAHlB;AAIII,WAAcJ,QAAQ,QAAR,EAAkB,YAAlB,CAJlB;AAKIK,UAAcL,QAAQ,eAAR,CALlB;AAMIM,SAAcN,QAAQ,cAAR,CANlB;AAOIO,WAAcP,QAAQ,gBAAR,CAPlB;AAQIQ,YAAcR,QAAQ,iBAAR,CARlB;AASIS,KAAcT,QAAQ,SAAR,CATlB;AAUIU,MAAcV,QAAQ,WAAR,CAVlB;AAWIW,OAAcD,MAAMC,MAXxB;;AAaA,GAAIC,WAAY,QAAZA,UAAY,CAASC,EAAT,CAAY;AAC1B,MAAOA,KAAM,IAAN,CAAaC,SAAb,CAAyBT,UAAUQ,EAAV,CAAhC;AACD,CAFD;;AAIA,GAAIE,qBAAsB,QAAtBA,oBAAsB,CAASC,YAAT,CAAsB;AAC9C,GAAIC,SAAUD,aAAaE,EAA3B;AACA,GAAGD,OAAH,CAAW;AACTD,aAAaE,EAAb,CAAkBJ,SAAlB;AACAG;AACD;AACF,CAND;;AAQA,GAAIE,oBAAqB,QAArBA,mBAAqB,CAASH,YAAT,CAAsB;AAC7C,MAAOA,cAAaI,EAAb,GAAoBN,SAA3B;AACD,CAFD;;AAIA,GAAIO,mBAAoB,QAApBA,kBAAoB,CAASL,YAAT,CAAsB;AAC5C,GAAG,CAACG,mBAAmBH,YAAnB,CAAJ,CAAqC;AACnCA,aAAaI,EAAb,CAAkBN,SAAlB;AACAC,oBAAoBC,YAApB;AACD;AACF,CALD;;AAOA,GAAIM,cAAe,QAAfA,aAAe,CAASC,QAAT,CAAmBC,UAAnB,CAA8B;AAC/ClB,SAASiB,QAAT;AACA,KAAKL,EAAL,CAAUJ,SAAV;AACA,KAAKM,EAAL,CAAUG,QAAV;AACAA,SAAW,GAAIE,qBAAJ,CAAyB,IAAzB,CAAX;AACA,GAAI;AACF,GAAIR,SAAeO,WAAWD,QAAX,CAAnB;AACIP,aAAeC,OADnB;AAEA,GAAGA,SAAW,IAAd,CAAmB;AACjB,GAAG,MAAOA,SAAQS,WAAf,GAA+B,UAAlC,CAA6CT,QAAU,kBAAU,CAAED,aAAaU,WAAb,GAA6B,CAAnD,CAA7C;AACKrB,UAAUY,OAAV;AACL,KAAKC,EAAL,CAAUD,OAAV;AACD;AACF,CAAC,MAAMU,CAAN,CAAQ;AACRJ,SAASK,KAAT,CAAeD,CAAf;AACA;AACD,CAAC,GAAGR,mBAAmB,IAAnB,CAAH,CAA4BJ,oBAAoB,IAApB;AAC/B,CAjBD;;AAmBAO,aAAaO,SAAb,CAAyBrB,YAAY,EAAZ,CAAgB;AACvCkB,YAAa,QAASA,YAAT,EAAsB,CAAEL,kBAAkB,IAAlB,EAA0B,CADxB,CAAhB,CAAzB;;;AAIA,GAAII,sBAAuB,QAAvBA,qBAAuB,CAAST,YAAT,CAAsB;AAC/C,KAAKc,EAAL,CAAUd,YAAV;AACD,CAFD;;AAIAS,qBAAqBI,SAArB,CAAiCrB,YAAY,EAAZ,CAAgB;AAC/CuB,KAAM,QAASA,KAAT,CAAcC,KAAd,CAAoB;AACxB,GAAIhB,cAAe,KAAKc,EAAxB;AACA,GAAG,CAACX,mBAAmBH,YAAnB,CAAJ,CAAqC;AACnC,GAAIO,UAAWP,aAAaI,EAA5B;AACA,GAAI;AACF,GAAIa,GAAIrB,UAAUW,SAASQ,IAAnB,CAAR;AACA,GAAGE,CAAH,CAAK,MAAOA,GAAEC,IAAF,CAAOX,QAAP,CAAiBS,KAAjB,CAAP;AACN,CAAC,MAAML,CAAN,CAAQ;AACR,GAAI;AACFN,kBAAkBL,YAAlB;AACD,CAFD,OAEU;AACR,KAAMW,EAAN;AACD;AACF;AACF;AACF,CAhB8C;AAiB/CC,MAAO,QAASA,MAAT,CAAeI,KAAf,CAAqB;AAC1B,GAAIhB,cAAe,KAAKc,EAAxB;AACA,GAAGX,mBAAmBH,YAAnB,CAAH,CAAoC,KAAMgB,MAAN;AACpC,GAAIT,UAAWP,aAAaI,EAA5B;AACAJ,aAAaI,EAAb,CAAkBN,SAAlB;AACA,GAAI;AACF,GAAImB,GAAIrB,UAAUW,SAASK,KAAnB,CAAR;AACA,GAAG,CAACK,CAAJ,CAAM,KAAMD,MAAN;AACNA,MAAQC,EAAEC,IAAF,CAAOX,QAAP,CAAiBS,KAAjB,CAAR;AACD,CAAC,MAAML,CAAN,CAAQ;AACR,GAAI;AACFZ,oBAAoBC,YAApB;AACD,CAFD,OAEU;AACR,KAAMW,EAAN;AACD;AACF,CAACZ,oBAAoBC,YAApB;AACF,MAAOgB,MAAP;AACD,CAlC8C;AAmC/CG,SAAU,QAASA,SAAT,CAAkBH,KAAlB,CAAwB;AAChC,GAAIhB,cAAe,KAAKc,EAAxB;AACA,GAAG,CAACX,mBAAmBH,YAAnB,CAAJ,CAAqC;AACnC,GAAIO,UAAWP,aAAaI,EAA5B;AACAJ,aAAaI,EAAb,CAAkBN,SAAlB;AACA,GAAI;AACF,GAAImB,GAAIrB,UAAUW,SAASY,QAAnB,CAAR;AACAH,MAAQC,EAAIA,EAAEC,IAAF,CAAOX,QAAP,CAAiBS,KAAjB,CAAJ,CAA8BlB,SAAtC;AACD,CAAC,MAAMa,CAAN,CAAQ;AACR,GAAI;AACFZ,oBAAoBC,YAApB;AACD,CAFD,OAEU;AACR,KAAMW,EAAN;AACD;AACF,CAACZ,oBAAoBC,YAApB;AACF,MAAOgB,MAAP;AACD;AACF,CApD8C,CAAhB,CAAjC;;;AAuDA,GAAII,aAAc,QAASC,WAAT,CAAoBb,UAApB,CAA+B;AAC/CjB,WAAW,IAAX,CAAiB6B,WAAjB,CAA8B,YAA9B,CAA4C,IAA5C,EAAkDE,EAAlD,CAAuDjC,UAAUmB,UAAV,CAAvD;AACD,CAFD;;AAIAhB,YAAY4B,YAAYP,SAAxB,CAAmC;AACjCU,UAAW,QAASA,UAAT,CAAmBhB,QAAnB,CAA4B;AACrC,MAAO,IAAID,aAAJ,CAAiBC,QAAjB,CAA2B,KAAKe,EAAhC,CAAP;AACD,CAHgC;AAIjCE,QAAS,QAASA,QAAT,CAAiB3B,EAAjB,CAAoB;AAC3B,GAAI4B,MAAO,IAAX;AACA,MAAO,KAAKvC,KAAKwC,OAAL,EAAgBzC,OAAOyC,OAA5B,EAAqC,SAASC,OAAT,CAAkBC,MAAlB,CAAyB;AACnEvC,UAAUQ,EAAV;AACA,GAAIG,cAAeyB,KAAKF,SAAL,CAAe;AAChCR,KAAO,cAASC,KAAT,CAAe;AACpB,GAAI;AACF,MAAOnB,IAAGmB,KAAH,CAAP;AACD,CAAC,MAAML,CAAN,CAAQ;AACRiB,OAAOjB,CAAP;AACAX,aAAaU,WAAb;AACD;AACF,CAR+B;AAShCE,MAAOgB,MATyB;AAUhCT,SAAUQ,OAVsB,CAAf,CAAnB;;AAYD,CAdM,CAAP;AAeD,CArBgC,CAAnC;;;AAwBAnC,YAAY4B,WAAZ,CAAyB;AACvBS,KAAM,QAASA,KAAT,CAAcC,CAAd,CAAgB;AACpB,GAAIC,GAAI,MAAO,KAAP,GAAgB,UAAhB,CAA6B,IAA7B,CAAoCX,WAA5C;AACA,GAAIY,QAASpC,UAAUN,SAASwC,CAAT,EAAY1C,UAAZ,CAAV,CAAb;AACA,GAAG4C,MAAH,CAAU;AACR,GAAIC,YAAa3C,SAAS0C,OAAOd,IAAP,CAAYY,CAAZ,CAAT,CAAjB;AACA,MAAOG,YAAWC,WAAX,GAA2BH,CAA3B,CAA+BE,UAA/B,CAA4C,GAAIF,EAAJ,CAAM,SAASxB,QAAT,CAAkB;AACzE,MAAO0B,YAAWV,SAAX,CAAqBhB,QAArB,CAAP;AACD,CAFkD,CAAnD;AAGD;AACD,MAAO,IAAIwB,EAAJ,CAAM,SAASxB,QAAT,CAAkB;AAC7B,GAAI4B,MAAO,KAAX;AACAhD,UAAU,UAAU;AAClB,GAAG,CAACgD,IAAJ,CAAS;AACP,GAAI;AACF,GAAGzC,MAAMoC,CAAN,CAAS,KAAT,CAAgB,SAASM,EAAT,CAAY;AAC7B7B,SAASQ,IAAT,CAAcqB,EAAd;AACA,GAAGD,IAAH,CAAQ,MAAOxC,OAAP;AACT,CAHE,IAGIA,MAHP,CAGc;AACf,CAAC,MAAMgB,CAAN,CAAQ;AACR,GAAGwB,IAAH,CAAQ,KAAMxB,EAAN;AACRJ,SAASK,KAAT,CAAeD,CAAf;AACA;AACD,CAACJ,SAASY,QAAT;AACH;AACF,CAbD;AAcA,MAAO,WAAU,CAAEgB,KAAO,IAAP,CAAc,CAAjC;AACD,CAjBM,CAAP;AAkBD,CA5BsB;AA6BvBE,GAAI,QAASA,GAAT,EAAa;AACf,IAAI,GAAIC,GAAI,CAAR,CAAWC,EAAIC,UAAUC,MAAzB,CAAiCC,MAAQC,MAAMJ,CAAN,CAA7C,CAAuDD,EAAIC,CAA3D,GAA8DG,MAAMJ,CAAN,EAAWE,UAAUF,GAAV,CAAX,CAA9D;AACA,MAAO,KAAK,MAAO,KAAP,GAAgB,UAAhB,CAA6B,IAA7B,CAAoClB,WAAzC,EAAsD,SAASb,QAAT,CAAkB;AAC7E,GAAI4B,MAAO,KAAX;AACAhD,UAAU,UAAU;AAClB,GAAG,CAACgD,IAAJ,CAAS;AACP,IAAI,GAAIG,GAAI,CAAZ,CAAeA,EAAII,MAAMD,MAAzB,CAAiC,EAAEH,CAAnC,CAAqC;AACnC/B,SAASQ,IAAT,CAAc2B,MAAMJ,CAAN,CAAd;AACA,GAAGH,IAAH,CAAQ;AACT,CAAC5B,SAASY,QAAT;AACH;AACF,CAPD;AAQA,MAAO,WAAU,CAAEgB,KAAO,IAAP,CAAc,CAAjC;AACD,CAXM,CAAP;AAYD,CA3CsB,CAAzB;;;AA8CA1C,KAAK2B,YAAYP,SAAjB,CAA4BzB,UAA5B,CAAwC,UAAU,CAAE,MAAO,KAAP,CAAc,CAAlE;;AAEAL,QAAQA,QAAQ6D,CAAhB,CAAmB,CAACvB,WAAYD,WAAb,CAAnB;;AAEApC,QAAQ,gBAAR,EAA0B,YAA1B","file":"es7.observable.js","sourceRoot":"d:/Work/Office/react-native-on-web/cli/tmpl/project","sourcesContent":["'use strict';\n// https://github.com/zenparsing/es-observable\nvar $export     = require('./_export')\n  , global      = require('./_global')\n  , core        = require('./_core')\n  , microtask   = require('./_microtask')()\n  , OBSERVABLE  = require('./_wks')('observable')\n  , aFunction   = require('./_a-function')\n  , anObject    = require('./_an-object')\n  , anInstance  = require('./_an-instance')\n  , redefineAll = require('./_redefine-all')\n  , hide        = require('./_hide')\n  , forOf       = require('./_for-of')\n  , RETURN      = forOf.RETURN;\n\nvar getMethod = function(fn){\n  return fn == null ? undefined : aFunction(fn);\n};\n\nvar cleanupSubscription = function(subscription){\n  var cleanup = subscription._c;\n  if(cleanup){\n    subscription._c = undefined;\n    cleanup();\n  }\n};\n\nvar subscriptionClosed = function(subscription){\n  return subscription._o === undefined;\n};\n\nvar closeSubscription = function(subscription){\n  if(!subscriptionClosed(subscription)){\n    subscription._o = undefined;\n    cleanupSubscription(subscription);\n  }\n};\n\nvar Subscription = function(observer, subscriber){\n  anObject(observer);\n  this._c = undefined;\n  this._o = observer;\n  observer = new SubscriptionObserver(this);\n  try {\n    var cleanup      = subscriber(observer)\n      , subscription = cleanup;\n    if(cleanup != null){\n      if(typeof cleanup.unsubscribe === 'function')cleanup = function(){ subscription.unsubscribe(); };\n      else aFunction(cleanup);\n      this._c = cleanup;\n    }\n  } catch(e){\n    observer.error(e);\n    return;\n  } if(subscriptionClosed(this))cleanupSubscription(this);\n};\n\nSubscription.prototype = redefineAll({}, {\n  unsubscribe: function unsubscribe(){ closeSubscription(this); }\n});\n\nvar SubscriptionObserver = function(subscription){\n  this._s = subscription;\n};\n\nSubscriptionObserver.prototype = redefineAll({}, {\n  next: function next(value){\n    var subscription = this._s;\n    if(!subscriptionClosed(subscription)){\n      var observer = subscription._o;\n      try {\n        var m = getMethod(observer.next);\n        if(m)return m.call(observer, value);\n      } catch(e){\n        try {\n          closeSubscription(subscription);\n        } finally {\n          throw e;\n        }\n      }\n    }\n  },\n  error: function error(value){\n    var subscription = this._s;\n    if(subscriptionClosed(subscription))throw value;\n    var observer = subscription._o;\n    subscription._o = undefined;\n    try {\n      var m = getMethod(observer.error);\n      if(!m)throw value;\n      value = m.call(observer, value);\n    } catch(e){\n      try {\n        cleanupSubscription(subscription);\n      } finally {\n        throw e;\n      }\n    } cleanupSubscription(subscription);\n    return value;\n  },\n  complete: function complete(value){\n    var subscription = this._s;\n    if(!subscriptionClosed(subscription)){\n      var observer = subscription._o;\n      subscription._o = undefined;\n      try {\n        var m = getMethod(observer.complete);\n        value = m ? m.call(observer, value) : undefined;\n      } catch(e){\n        try {\n          cleanupSubscription(subscription);\n        } finally {\n          throw e;\n        }\n      } cleanupSubscription(subscription);\n      return value;\n    }\n  }\n});\n\nvar $Observable = function Observable(subscriber){\n  anInstance(this, $Observable, 'Observable', '_f')._f = aFunction(subscriber);\n};\n\nredefineAll($Observable.prototype, {\n  subscribe: function subscribe(observer){\n    return new Subscription(observer, this._f);\n  },\n  forEach: function forEach(fn){\n    var that = this;\n    return new (core.Promise || global.Promise)(function(resolve, reject){\n      aFunction(fn);\n      var subscription = that.subscribe({\n        next : function(value){\n          try {\n            return fn(value);\n          } catch(e){\n            reject(e);\n            subscription.unsubscribe();\n          }\n        },\n        error: reject,\n        complete: resolve\n      });\n    });\n  }\n});\n\nredefineAll($Observable, {\n  from: function from(x){\n    var C = typeof this === 'function' ? this : $Observable;\n    var method = getMethod(anObject(x)[OBSERVABLE]);\n    if(method){\n      var observable = anObject(method.call(x));\n      return observable.constructor === C ? observable : new C(function(observer){\n        return observable.subscribe(observer);\n      });\n    }\n    return new C(function(observer){\n      var done = false;\n      microtask(function(){\n        if(!done){\n          try {\n            if(forOf(x, false, function(it){\n              observer.next(it);\n              if(done)return RETURN;\n            }) === RETURN)return;\n          } catch(e){\n            if(done)throw e;\n            observer.error(e);\n            return;\n          } observer.complete();\n        }\n      });\n      return function(){ done = true; };\n    });\n  },\n  of: function of(){\n    for(var i = 0, l = arguments.length, items = Array(l); i < l;)items[i] = arguments[i++];\n    return new (typeof this === 'function' ? this : $Observable)(function(observer){\n      var done = false;\n      microtask(function(){\n        if(!done){\n          for(var i = 0; i < items.length; ++i){\n            observer.next(items[i]);\n            if(done)return;\n          } observer.complete();\n        }\n      });\n      return function(){ done = true; };\n    });\n  }\n});\n\nhide($Observable.prototype, OBSERVABLE, function(){ return this; });\n\n$export($export.G, {Observable: $Observable});\n\nrequire('./_set-species')('Observable');"]}