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

Merge pull request #1342 from Salakar/master

Browse Source 
[tests] fix broken utils tests
This commit is contained in:
Michael Diarmid
2018-05-22 22:16:17 +01:00
committed by GitHub
parent 04a09aa2ff c159815e62
commit 7e945bb732
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);