EFTA01219926.pdf

Subject: am:radd(u.schedule(dispatchNext,0,(value:n,subject:a))))else{var b=t.length<=1? t[0]:t;tadd(u.schedule(dispatchNext,O, (value:b,subject:a)))) );b.source=t,ttyCatch_l.tryCatch(o).apply(s,a.concat(b))=---errorObject_l.e rrotObject&&n.error(errorObject_l.errorObject.e)) tadd(n.subscribe(c))),r) (Observable_1.Observable)function dispatchNext(e)(var r=e.value,t=e.subject;t.next(r),t.complete())function dispatchError(e){var r=e.eme.subject.error(r)}exports.BoundCallbackObservable=BoundCallbackObservable; Date: Sat, 01 Jan 4501 05:00:00 +0000 ), ("../AsyncSubject":247,"../Observable":251,"../util/errorObject":579,"../util/tryCatch":593)] ,392:[function(require,module,exports)f "use strict";var extends=this&&this. extendsl ifunction(e,r)ffor(var t in r)r.hasOwnProperty(t)&&(e[t]=r[t]);function c(){this.constructor=e}e.prototype=null===r? Object.create(r):(c.prototype=r.prototype,new c)),Observable_l=require("../Observable"),tryCatch_l=require("../util/tryCatch"),errorObject_ 1=require("../util/errorObject"),AsyncSubject_l=require("../AsyncSubject"),BoundNodeCallback0 bservable=function(e)(function r(r,t,c,s,o) (e.call(this),this.callbackFunc=r,this.selector=t,this.args=c,this.context=s,this.scheduler=o }return extends(r,e),r.create=function(e,t,c)freturn void 0===t&&(t=void 0),function() (for(var s=[],o=0;o<arguments.length;o++)s[o-0]=arguments[o];return new r(e,t,s,this,c))),r.prototype._subscribe=function(e)Ivar r=this.callbackFunc,t=this.args,c=this.scheduler,s=this.subject;if(c)return c.schedule(dispatch,0,{source:this,subscriber:e,context:this.context});if(!s) (s=this.subject=new AsyncSubject_l.AsyncSubject;var o=function e()(for(var r= [],t=0;t<arguments.length;t++)r[t-O]=arguments[t];var c=e.source,s=c.selector,o=c.subject,a=r.shift();if(a)o.error(a);else if(s){var u=tryCatch_l.tryCatch(s).apply(this,r);u===errorObject_l.errorObject? o.error(errorObject_l.errorObject.e):(o.next(u),o.complete()))else o.next(r.length<=1? r[0]:r),o.complete());o.source=this,tryCatch_l.tryCatch(r).apply(this.context,t.concat(o))=== errorObject_l.errorObjectfi&s.error(errorObject_l.errorObject.e))return s.subscribe(e)),r) (Observable_1.0bservable);function dispatch(e)(var r=this,t=e.source,c=e.subscriber,s=e.context,o=t,a=o.callbackFunc,u=o.args,b=o.scheduler,i=t. subject;if(!i)fi=t.subject=new AsyncSubject_l.AsyncSubject;var n=function e(){for(var t= [1,c=0;c<arguments.length;c++)t[c-O]=arguments[c];var s=e.source,o=s.selector,a=s.subject,u=t.shift();if(u)r.add(b.schedule(dispatchError,O, (err:u,subject:a)));else if(o)(var i=tryCatch_l.tryCatch(o).apply(this,t);i===errorObject_l.errorObject? r.add(b.schedule(dispatchError,O, (err:errorObject_l.errorObject.e,subject:a))):r.add(b.schedule(dispatchNext,O, (value:i,subject:a))))else(var n=t.length<=1?t[0]:t;r.add(b.schedule(dispatchNext,O, (value:n,subject:a)))));n.source=t,tryCatch_l.tryCatch(a).apply(s,u.concat(n))===errorObject_ 1.errorObject&&r.add(b.schedule(dispatchError,0, (err:errorObject_l.errorObject.e,subject:i))))r.add(i.subscribe(c)))function dispatchNext(e) (var r=e.value,t=e.subject;t.next(r),t.complete())function dispatchError(e)(var r=e.err;e.subject.error(r))exports.BoundNodeCallbackObservable=PoundNodeCallbackObservable; EFTA01219926