diff --git a/src/Observable.js b/src/Observable.js index d918d74..6b5bcae 100644 --- a/src/Observable.js +++ b/src/Observable.js @@ -315,13 +315,13 @@ export class Observable { })); } - async promisify() { + async all() { let promise = new Promise((resolve, reject) => { this .reduce((previous, current) => { previous.push(current); return previous; - }, []) + }, []) .subscribe(o => resolve(o), e => reject(e)); }); @@ -329,7 +329,7 @@ export class Observable { } async *[Symbol.asyncIterator]() { - let values = await this.promisify() + let values = await this.all() for (let value of values) { yield new Promise((resolve, _) => resolve(value)) } diff --git a/test/promisify.js b/test/all.js similarity index 66% rename from test/promisify.js rename to test/all.js index cd8b9b8..14ec24c 100644 --- a/test/promisify.js +++ b/test/all.js @@ -1,10 +1,10 @@ import assert from 'assert'; -describe('promisify', ()=> { - it('should receive all the observed values in order as an array', async ()=>{ +describe('all', ()=> { + it('should receive all the observed values in order as an array', async () => { let observable = Observable.of(1,2,3,4); - let values = await observable.promisify(); + let values = await observable.all(); assert.deepEqual([1,2,3,4], values); }); -}); \ No newline at end of file +});