text: define("scalejs.reactive/reactive",["require","rx","rx.binding","rx.time","rx.experimental"],function(e,r){return r.Observable.fromRequire=function(n){return r.Observable.create(function(r){e(n,function(){r.onNext(arguments),r.onCompleted()})})},r.Observable.fromEnumerable=function(e){return r.Observable.createWithDisposable(function(n){var t=r.Disposable.create(function(){}),a=e.GetEnumerator();return r.Scheduler.currentThread.scheduleRecursive(function(e){try{!t.isDisposed&&a.MoveNext()?(n.onNext(a.Current()),e()):(a.Dispose(),n.onCompleted())}catch(r){a.Dispose(),n.onError(r)}}),t})},r}),define("scalejs.reactive/messageBus",["scalejs!core","rx","rx.binding"],function(e,r){function n(e){return c(o,e)||(o[e]=new r.Subject),o[e]}function t(e){return c(l,e)||(l[e]=new r.BehaviorSubject),l[e]}function a(e,r){var t=n(e);t.onNext(r)}function s(e,r,t){var a=n(e);if(1===arguments.length)return a.asObservable();if(2===arguments.length)return a.subscribe(r);if(3===arguments.length)return a.where(r).subscribe(t);throw{name:"Illegal Argument",message:arguments.length+" arguments have been provided. "+"Valid arguments are subject (required), filter (optional), and receiver (optional)."}}function i(e,r){var n=t(e);n.onNext(r)}function u(e,r,n){var a=t(e);if(1===arguments.length)return a.asObservable();if(2===arguments.length)return a.subscribe(r);if(3===arguments.length)return a.where(r).subscribe(n);throw{name:"Illegal Argument",message:arguments.length+" arguments have been provided. "+"Valid arguments are subject (required), filter (optional), and receiver (optional)."}}var c=e.object.has,o={},l={};return{notify:a,receive:s,set:i,get:u}}),define("scalejs.reactive",["scalejs!core","./scalejs.reactive/reactive","./scalejs.reactive/messageBus"],function(e,r,n){var t=e.object.merge;e.registerExtension({reactive:t(r,{messageBus:n})})});