redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-06 02:15:48 +03:00
Code Activity

Add regression test for return_buffers in pub/sub mode (#911)

Browse Source
This commit is contained in:
Anton Nesterov
2015-10-30 16:09:17 +03:00
parent cc93e0b3a7
commit 3e64ce7bc3
1 changed files with 54 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
test/return_buffers.spec.js
View File

@@ -7,7 +7,7 @@ var redis = config.redis;
describe("return_buffers", function () {
helper.allTests(function(parser, ip) {
helper.allTests(function(parser, ip, basicArgs) {
describe("using " + parser + " and " + ip, function () {
var client;
@@ -229,6 +229,58 @@ describe("return_buffers", function () {
});
});
});
describe('publish/subscribe', function (done) {
var pub;
var sub;
var channel = "test channel";
var message = new Buffer("test message");
var args = config.configureClient(parser, ip, {
return_buffers: true
});
beforeEach(function (done) {
var pubConnected;
var subConnected;
pub = redis.createClient.apply(redis.createClient, basicArgs);
sub = redis.createClient.apply(redis.createClient, args);
pub.once("connect", function () {
pub.flushdb(function () {
pubConnected = true;
if (subConnected) {
done();
}
});
});
sub.once("connect", function () {
subConnected = true;
if (pubConnected) {
done();
}
});
});
it('receives buffer messages', function (done) {
sub.on("subscribe", function (chnl, count) {
pub.publish(channel, message);
});
sub.on("message", function (chnl, msg) {
assert.strictEqual(true, Buffer.isBuffer(msg));
assert.strictEqual("<Buffer 74 65 73 74 20 6d 65 73 73 61 67 65>", msg.inspect());
return done();
});
sub.subscribe(channel);
});
afterEach(function () {
sub.end();
pub.end();
});
});
});
});
});
});