We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 907acee commit 1698f8cCopy full SHA for 1698f8c
1 file changed
lib/sockets.js
@@ -218,9 +218,9 @@ addSocketMethods(SubSocket);
218
SubSocket.prototype.connect = function(source, topic, callback) {
219
// Support the general form of connect
220
if (callback === undefined && typeof topic === 'function') {
221
- callback = topic;
222
- topic = '';
223
- }
+ callback = topic; topic = '';
+ } else topic = topic || '';
+
224
var ch = this.ch, queue = this.queue, self = this;
225
ch.assertExchange(source,
226
this.options.routing || 'fanout',
0 commit comments