(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);

};

});

};

})();