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 ... 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
https://www.justice.gov/epstein/files/DataSet%209/EFTA01219926.pdf