(function () {
 var events = OpenLayers.Events;
 var root;
 var global = this;
 if (typeof ProvideCustomRxRootObject == "undefined") {
 root = global.Rx;
 }
 else {
 root = ProvideCustomRxRootObject();
 }

 var observable = root.Observable;
 var observableCreate = observable.Create;

 events.prototype.toObservable = function (eventType) {
 var parent = this;
 var scope = parent.object;
 return observableCreate(function (observer) {
 var handler = function (obj) {
 try {
 observer.OnNext(obj);
 }
 catch (err) {
 observer.OnError(err);
 }
 }
 parent.register(eventType, scope, handler);
 return function () {
 parent.unregister(eventType, scope, handler);
 };
 });
 };
})();