Fix for #187

lib/client.js

@@ -35,8 +35,8 @@ var MqttClient = module.exports =
 function MqttClient(streamBuilder, options) {
   var that = this;
 
-  if (!this instanceof MqttClient) {
-    return new MqttClient(stream, options);
+  if (!(this instanceof MqttClient)) {
+    return new MqttClient(streamBuilder, options);
   }
 
   this.options = options || {};

test/abstract_client.js

@@ -2,7 +2,8 @@
 /**
  * Testing dependencies
  */
-var should = require('should');
+var should = require('should')
+  , MqttClient = require('../lib/client');
 
 module.exports = function(server, createClient, port) {
   describe('closing', function() {

test/client.js

@@ -3,6 +3,7 @@
  */
 
 var mqtt = require('..')
+  , should = require('should')
   , abstractClientTests = require("./abstract_client");
 
 /**
@@ -73,10 +74,28 @@ var server = mqtt.createServer(function (client) {
 
 
 describe('MqttClient', function() {
+  describe('creating', function() {
+    it('should allow instantiation of MqttClient without the \'new\' operator' , function(done) {
+      should(function() {
+	var client;
+
+	try {
+	  client = mqtt.MqttClient(function() {
+	    throw Error('break');
+	  }, {});
+	} catch (err) {
+	  if (err.message !== 'break') {
+	    throw err;
+	  }
+	  done();
+	}
+      }).not.throw("Object #<Object> has no method '_setupStream'");
+    });
+  });
+
   abstractClientTests(server, createClient, port);
-
+  
   describe('message ids', function() {
-
     it('should increment the message id', function() {
       var client = createClient();
       var currentId = client._nextId();