BoundCallbackObservable.js 1.2 KB

123456789101112131415161718192021222324252627
  1. var __extends = (this && this.__extends) || (function () {
  2. var extendStatics = function (d, b) {
  3. extendStatics = Object.setPrototypeOf ||
  4. ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
  5. function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
  6. return extendStatics(d, b);
  7. }
  8. return function (d, b) {
  9. extendStatics(d, b);
  10. function __() { this.constructor = d; }
  11. d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
  12. };
  13. })();
  14. import { Observable, bindCallback } from 'rxjs';
  15. var BoundCallbackObservable = (function (_super) {
  16. __extends(BoundCallbackObservable, _super);
  17. function BoundCallbackObservable() {
  18. return _super !== null && _super.apply(this, arguments) || this;
  19. }
  20. BoundCallbackObservable.create = function (func, selector, scheduler) {
  21. if (selector === void 0) { selector = undefined; }
  22. return bindCallback(func, selector, scheduler);
  23. };
  24. return BoundCallbackObservable;
  25. }(Observable));
  26. export { BoundCallbackObservable };
  27. //# sourceMappingURL=BoundCallbackObservable.js.map