unboundedpress/node_modules/observable-to-promise/index.js
2019-07-23 04:28:47 +00:00

20 lines
368 B
JavaScript

'use strict';
var isObservable = require('is-observable');
var symbolObservable = require('symbol-observable');
module.exports = function (val) {
if (!isObservable(val)) {
throw new TypeError('Expected an observable');
}
var ret = [];
return val[symbolObservable]()
.forEach(function (x) {
ret.push(x);
})
.then(function () {
return ret;
});
};