zimgao/gochan
1
0
Fork 0
Code Issues Pull requests Packages Wiki Activity Actions

Fix #2.

Browse source
This commit is contained in:
David Braun 2018-03-13 16:59:17 -04:00
parent a0e8ad6462
commit 95a575fd2d
No known key found for this signature in database
GPG key ID: 5694EEC4D129BDCF
2 changed files with 5 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

7
lib/index.js
View file

@ -235,7 +235,9 @@ const Channel = function(length = 0) {
const { order, promise } = Order(this); const { order, promise } = Order(this);
shifts.push(order); shifts.push(order);
setImmediate(processOrders); setImmediate(processOrders);
return Object.freeze(promise);
// Don't freeze promise because Bluebird expects it to be mutable.
return promise;
}, },
slice: (start, end = Infinity) => { slice: (start, end = Infinity) => {
@ -333,7 +335,8 @@ const Channel = function(length = 0) {
setImmediate(processOrders); setImmediate(processOrders);
} }
return Object.freeze(promise); // Don't freeze promise because Bluebird expects it to be mutable.
return promise;
}, },
writeOnly: () => writeOnly writeOnly: () => writeOnly

12
test/index.js
View file

@ -314,12 +314,6 @@ describe(`Channel object`, function() {
await channel.push(0, 1, 2); await channel.push(0, 1, 2);
}, new Error(`Can't push more than one value at a time.`)); }, new Error(`Can't push more than one value at a time.`));
}); });
it(`returns a frozen promise`, function() {
assert.throws(() => {
Channel().push(0).frozen = false;
});
});
}); });
it(`readOnly`, async function() { it(`readOnly`, async function() {
@ -375,12 +369,6 @@ describe(`Channel object`, function() {
assert.equal(await channel.shift(), 0); assert.equal(await channel.shift(), 0);
}); });
it(`returns a frozen promise`, function() {
assert.throws(() => {
Channel().shift().frozen = false;
});
});
}); });
describe(`slice`, function() { describe(`slice`, function() {