websocket-stream - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

demo-bundle.js

@@ -15,3 +15,3 @@ (function(){var require = function (file, cwd) {
 require.cache = {};
-require.extensions = [".js",".coffee"];
+require.extensions = [".js",".coffee",".json"];
 
@@ -143,6 +143,9 @@ require._core = {
     var process = {};
+    var global = typeof window !== 'undefined' ? window : {};
+    var definedProcess = false;
     
     require.define = function (filename, fn) {
-        if (require.modules.__browserify_process) {
+        if (!definedProcess && require.modules.__browserify_process) {
             process = require.modules.__browserify_process();
+            definedProcess = true;
         }
@@ -159,3 +162,3 @@
 
-            if (cached.parent === null) {
+            if (cached && cached.parent === null) {
                 cached.parent = module_;
@@ -189,3 +192,4 @@ }
                 filename,
-                process
+                process,
+                global
             );
@@ -199,3 +203,3 @@ module_.loaded = true;
 
-require.define("path",function(require,module,exports,__dirname,__filename,process){function filter (xs, fn) {
+require.define("path",function(require,module,exports,__dirname,__filename,process,global){function filter (xs, fn) {
     var res = [];
@@ -334,13 +338,61 @@ for (var i = 0; i < xs.length; i++) {
 };
+
+exports.relative = function(from, to) {
+  from = exports.resolve(from).substr(1);
+  to = exports.resolve(to).substr(1);
+
+  function trim(arr) {
+    var start = 0;
+    for (; start < arr.length; start++) {
+      if (arr[start] !== '') break;
+    }
+
+    var end = arr.length - 1;
+    for (; end >= 0; end--) {
+      if (arr[end] !== '') break;
+    }
+
+    if (start > end) return [];
+    return arr.slice(start, end - start + 1);
+  }
+
+  var fromParts = trim(from.split('/'));
+  var toParts = trim(to.split('/'));
+
+  var length = Math.min(fromParts.length, toParts.length);
+  var samePartsLength = length;
+  for (var i = 0; i < length; i++) {
+    if (fromParts[i] !== toParts[i]) {
+      samePartsLength = i;
+      break;
+    }
+  }
+
+  var outputParts = [];
+  for (var i = samePartsLength; i < fromParts.length; i++) {
+    outputParts.push('..');
+  }
+
+  outputParts = outputParts.concat(toParts.slice(samePartsLength));
+
+  return outputParts.join('/');
+};
+
 });
 
-require.define("__browserify_process",function(require,module,exports,__dirname,__filename,process){var process = module.exports = {};
+require.define("__browserify_process",function(require,module,exports,__dirname,__filename,process,global){var process = module.exports = {};
 
 process.nextTick = (function () {
-    var queue = [];
+    var canSetImmediate = typeof window !== 'undefined'
+        && window.setImmediate;
     var canPost = typeof window !== 'undefined'
         && window.postMessage && window.addEventListener
     ;
-    
+
+    if (canSetImmediate) {
+        return function (f) { return window.setImmediate(f) };
+    }
+
     if (canPost) {
+        var queue = [];
         window.addEventListener('message', function (ev) {
@@ -355,10 +407,11 @@ if (ev.source === window && ev.data === 'browserify-tick') {
         }, true);
-    }
-    
-    return function (fn) {
-        if (canPost) {
+
+        return function nextTick(fn) {
             queue.push(fn);
             window.postMessage('browserify-tick', '*');
-        }
-        else setTimeout(fn, 0);
+        };
+    }
+
+    return function nextTick(fn) {
+        setTimeout(fn, 0);
     };
@@ -386,7 +439,9 @@ })();
 })();
+
 });
 
-require.define("/js/websocket-stream/package.json",function(require,module,exports,__dirname,__filename,process){module.exports = {}});
+require.define("/js/websocket-stream/package.json",function(require,module,exports,__dirname,__filename,process,global){module.exports = {}
+});
 
-require.define("/js/websocket-stream/index.js",function(require,module,exports,__dirname,__filename,process){var stream = require('stream')
+require.define("/js/websocket-stream/index.js",function(require,module,exports,__dirname,__filename,process,global){var stream = require('stream')
 var util = require('util')
@@ -424,4 +479,4 @@
 WebsocketStream.prototype.onMessage = function(e, flags) {
-  this.emit('metadata', e, flags)
-  this.emit('data', e.data)
+  if (e.data) return this.emit('data', e.data, flags)
+  this.emit('data', e, flags)
 }
@@ -444,5 +499,6 @@
 }
+
 });
 
-require.define("stream",function(require,module,exports,__dirname,__filename,process){var events = require('events');
+require.define("stream",function(require,module,exports,__dirname,__filename,process,global){var events = require('events');
 var util = require('util');
@@ -566,5 +622,6 @@
 };
+
 });
 
-require.define("events",function(require,module,exports,__dirname,__filename,process){if (!process.EventEmitter) process.EventEmitter = function () {};
+require.define("events",function(require,module,exports,__dirname,__filename,process,global){if (!process.EventEmitter) process.EventEmitter = function () {};
 
@@ -578,2 +635,9 @@ var EventEmitter = exports.EventEmitter = process.EventEmitter;
 ;
+function indexOf (xs, x) {
+    if (xs.indexOf) return xs.indexOf(x);
+    for (var i = 0; i < xs.length; i++) {
+        if (x === xs[i]) return i;
+    }
+    return -1;
+}
 
@@ -715,3 +779,3 @@ // By default EventEmitters will print a warning if more than
   if (isArray(list)) {
-    var i = list.indexOf(listener);
+    var i = indexOf(list, listener);
     if (i < 0) return this;
@@ -742,6 +806,12 @@ list.splice(i, 1);
 };
+
 });
 
-require.define("util",function(require,module,exports,__dirname,__filename,process){var events = require('events');
+require.define("util",function(require,module,exports,__dirname,__filename,process,global){var events = require('events');
 
+exports.isArray = isArray;
+exports.isDate = function(obj){return Object.prototype.toString.call(obj) === '[object Date]'};
+exports.isRegExp = function(obj){return Object.prototype.toString.call(obj) === '[object RegExp]'};
+
+
 exports.print = function () {};
@@ -1057,7 +1127,43 @@ exports.puts = function () {};
 };
+
+var formatRegExp = /%[sdj%]/g;
+exports.format = function(f) {
+  if (typeof f !== 'string') {
+    var objects = [];
+    for (var i = 0; i < arguments.length; i++) {
+      objects.push(exports.inspect(arguments[i]));
+    }
+    return objects.join(' ');
+  }
+
+  var i = 1;
+  var args = arguments;
+  var len = args.length;
+  var str = String(f).replace(formatRegExp, function(x) {
+    if (x === '%%') return '%';
+    if (i >= len) return x;
+    switch (x) {
+      case '%s': return String(args[i++]);
+      case '%d': return Number(args[i++]);
+      case '%j': return JSON.stringify(args[i++]);
+      default:
+        return x;
+    }
+  });
+  for(var x = args[i]; i < len; x = args[++i]){
+    if (x === null || typeof x !== 'object') {
+      str += ' ' + x;
+    } else {
+      str += ' ' + exports.inspect(x);
+    }
+  }
+  return str;
+};
+
 });
 
-require.define("/node_modules/el-streamo/package.json",function(require,module,exports,__dirname,__filename,process){module.exports = {}});
+require.define("/node_modules/el-streamo/package.json",function(require,module,exports,__dirname,__filename,process,global){module.exports = {}
+});
 
-require.define("/node_modules/el-streamo/index.js",function(require,module,exports,__dirname,__filename,process){var through = require('through')
+require.define("/node_modules/el-streamo/index.js",function(require,module,exports,__dirname,__filename,process,global){var through = require('through')
 
@@ -1301,7 +1407,9 @@ function getElement(el) {
 
+
 });
 
-require.define("/node_modules/el-streamo/node_modules/through/package.json",function(require,module,exports,__dirname,__filename,process){module.exports = {"main":"index.js"}});
+require.define("/node_modules/el-streamo/node_modules/through/package.json",function(require,module,exports,__dirname,__filename,process,global){module.exports = {"main":"index.js"}
+});
 
-require.define("/node_modules/el-streamo/node_modules/through/index.js",function(require,module,exports,__dirname,__filename,process){var Stream = require('stream')
+require.define("/node_modules/el-streamo/node_modules/through/index.js",function(require,module,exports,__dirname,__filename,process,global){var Stream = require('stream')
 
@@ -1404,5 +1512,6 @@ // through
 
+
 });
 
-require.define("/js/websocket-stream/demo.js",function(require,module,exports,__dirname,__filename,process){var websocket = require('./')
+require.define("/js/websocket-stream/demo.js",function(require,module,exports,__dirname,__filename,process,global){var websocket = require('./')
 var elstreamo = require('el-streamo')
@@ -1412,4 +1521,5 @@ ws = websocket('ws://localhost:8080')
 ws.pipe(elstream)
+
 });
 require("/js/websocket-stream/demo.js");
 })();

index.js

@@ -46,4 +46,4 @@ var stream = require('stream')
 
-WebsocketStream.prototype.write = function(data, options) {
-  return this.ws.send(data, options)
+WebsocketStream.prototype.write = function(data) {
+  return this.ws.send(data)
 }
@@ -50,0 +50,0 @@

package.json

@@ -5,3 +5,3 @@ {
   "keywords": ["websocket", "websockets", "stream", "streams", "realtime"],
-  "version": "0.0.4",
+  "version": "0.0.5",
   "_npmUser": {
@@ -8,0 +8,0 @@ "name": "maxogden",

No alert changes

Improved metrics

Total package byte prevSize

57010

increased by4.92%

Lines of code

1318

increased by6.98%

No dependency changes