12345678910111213141516171819202122232425 |
- 'use strict';
- var $ = require('../internals/export');
- var getBuiltIn = require('../internals/get-built-in');
- var isConstructor = require('../internals/is-constructor');
- var OBSERVABLE_FORCED = require('../internals/observable-forced');
- var Array = getBuiltIn('Array');
- // `Observable.of` method
- // https://github.com/tc39/proposal-observable
- $({ target: 'Observable', stat: true, forced: OBSERVABLE_FORCED }, {
- of: function of() {
- var C = isConstructor(this) ? this : getBuiltIn('Observable');
- var length = arguments.length;
- var items = Array(length);
- var index = 0;
- while (index < length) items[index] = arguments[index++];
- return new C(function (observer) {
- for (var i = 0; i < length; i++) {
- observer.next(items[i]);
- if (observer.closed) return;
- } observer.complete();
- });
- }
- });
|