diff options
Diffstat (limited to 'node_modules/observable-to-promise/index.js')
-rw-r--r-- | node_modules/observable-to-promise/index.js | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/node_modules/observable-to-promise/index.js b/node_modules/observable-to-promise/index.js deleted file mode 100644 index 7109b70e5..000000000 --- a/node_modules/observable-to-promise/index.js +++ /dev/null @@ -1,23 +0,0 @@ -'use strict'; -const isObservable = require('is-observable'); -const symbolObservable = require('symbol-observable').default; - -module.exports = val => { - if (!isObservable(val)) { - throw new TypeError('Expected an Observable'); - } - - const ret = []; - - return new Promise((resolve, reject) => { - val[symbolObservable]().subscribe({ - next: x => { - ret.push(x); - }, - error: reject, - complete: () => { - resolve(ret); - } - }); - }); -}; |