redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-07 13:22:56 +03:00
Code Activity

update utils.spec queue tests to support denque push() differences

Browse Source
This commit is contained in:
Salakar
2018-05-22 22:04:47 +01:00
parent 04a09aa2ff
commit c159815e62
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
test/utils.spec.js
View File

@@ -131,17 +131,22 @@ describe('utils.js', function () {
}); });
it('elements in the offline queue. Reply after the offline queue is empty and respect the command_obj callback', function (done) { it('elements in the offline queue. Reply after the offline queue is empty and respect the command_obj callback', function (done) {
clientMock.offline_queue.push(create_command_obj(), create_command_obj()); clientMock.offline_queue.push(create_command_obj());
clientMock.offline_queue.push(create_command_obj());
utils.reply_in_order(clientMock, function () { utils.reply_in_order(clientMock, function () {
assert.strictEqual(clientMock.offline_queue.length, 0); assert.strictEqual(clientMock.offline_queue.length, 0);
assert.strictEqual(res_count, 2); assert.strictEqual(res_count, 2);
done(); done();
}, null, null); }, null, null);
while (clientMock.offline_queue.length) clientMock.offline_queue.shift().callback(null, 'foo'); while (clientMock.offline_queue.length) {
clientMock.offline_queue.shift().callback(null, 'foo');
}
}); });
it('elements in the offline queue. Reply after the offline queue is empty and respect the command_obj error emit', function (done) { it('elements in the offline queue. Reply after the offline queue is empty and respect the command_obj error emit', function (done) {
clientMock.command_queue.push({}, create_command_obj(), {}); clientMock.command_queue.push({});
clientMock.command_queue.push(create_command_obj());
clientMock.command_queue.push({});
utils.reply_in_order(clientMock, function () { utils.reply_in_order(clientMock, function () {
assert.strictEqual(clientMock.command_queue.length, 0); assert.strictEqual(clientMock.command_queue.length, 0);
assert(emitted); assert(emitted);
@@ -158,8 +163,10 @@ describe('utils.js', function () {
}); });
it('elements in the offline queue and the command_queue. Reply all other commands got handled respect the command_obj', function (done) { it('elements in the offline queue and the command_queue. Reply all other commands got handled respect the command_obj', function (done) {
clientMock.command_queue.push(create_command_obj(), create_command_obj()); clientMock.command_queue.push(create_command_obj());
clientMock.offline_queue.push(create_command_obj(), {}); clientMock.command_queue.push(create_command_obj());
clientMock.command_queue.push(create_command_obj());
clientMock.offline_queue.push({});
utils.reply_in_order(clientMock, function (err, res) { utils.reply_in_order(clientMock, function (err, res) {
assert.strictEqual(clientMock.command_queue.length, 0); assert.strictEqual(clientMock.command_queue.length, 0);
assert.strictEqual(clientMock.offline_queue.length, 0); assert.strictEqual(clientMock.offline_queue.length, 0);