← Back
Editing: esnext.observable.of.js
'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(); }); } });
Save File
Cancel