You've already forked node-redis
mirror of
https://github.com/redis/node-redis.git
synced 2025-08-07 13:22:56 +03:00
Fix test for appveyor
This commit is contained in:
@@ -104,14 +104,18 @@ describe("publish/subscribe", function () {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it('receives messages on subscribed channel', function (done) {
|
it('receives messages on subscribed channel', function (done) {
|
||||||
|
var end = helper.callFuncAfter(done, 2);
|
||||||
sub.on("subscribe", function (chnl, count) {
|
sub.on("subscribe", function (chnl, count) {
|
||||||
pub.publish(channel, message, helper.isNumber(1));
|
pub.publish(channel, message, function (err, res) {
|
||||||
|
helper.isNumber(1)(err, res);
|
||||||
|
end();
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
sub.on("message", function (chnl, msg) {
|
sub.on("message", function (chnl, msg) {
|
||||||
assert.equal(chnl, channel);
|
assert.equal(chnl, channel);
|
||||||
assert.equal(msg, message);
|
assert.equal(msg, message);
|
||||||
return done();
|
end();
|
||||||
});
|
});
|
||||||
|
|
||||||
sub.subscribe(channel);
|
sub.subscribe(channel);
|
||||||
|
Reference in New Issue
Block a user