websocket-stream - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

demo-bundle.js

@@ -386,3 +386,3 @@ (function(){var require = function (file, cwd) {
 
-function WebsocketStream(server) {
+function WebsocketStream(server, protocol) {
   var me = this
@@ -392,5 +392,6 @@ stream.Stream.call(me)
   this.writable = true
-  me.ws = new WebSocket(server)
+  me.ws = new WebSocket(server, protocol)
   me.ws.onmessage = me.onMessage.bind(this)
   me.ws.onerror = me.onError.bind(this)
+  me.ws.onclose = me.onClose.bind(this)
 }
@@ -400,4 +401,4 @@
 
-module.exports = function(server) {
-  return new WebsocketStream(server)
+module.exports = function(server, protocol) {
+  return new WebsocketStream(server, protocol)
 }
@@ -416,2 +417,6 @@
 
+WebsocketStream.prototype.onClose = function(err) {
+  this.emit('end')
+}
+
 WebsocketStream.prototype.write = function(data) {
@@ -422,3 +427,3 @@ return this.ws.send(data)
 WebsocketStream.prototype.end = function() {
-  this.emit('end')
+  this.ws.close()
 }
@@ -1382,7 +1387,4 @@ });
 var elstreamo = require('el-streamo')
-
 ws = websocket('ws://localhost:8080')
-
 var elstream = elstreamo.writable('#messages')
-
 ws.pipe(elstream)
@@ -1389,0 +1391,0 @@ });

index.js

 var stream = require('stream')
 var util = require('util')
 
-function WebsocketStream(server) {
+function WebsocketStream(server, protocol) {
   var me = this
@@ -9,3 +9,3 @@ stream.Stream.call(me)
   this.writable = true
-  me.ws = new WebSocket(server)
+  me.ws = new WebSocket(server, protocol)
   me.ws.onmessage = me.onMessage.bind(this)
@@ -18,4 +18,4 @@ me.ws.onerror = me.onError.bind(this)
 
-module.exports = function(server) {
-  return new WebsocketStream(server)
+module.exports = function(server, protocol) {
+  return new WebsocketStream(server, protocol)
 }
@@ -43,3 +43,3 @@
 WebsocketStream.prototype.end = function() {
-  this.emit('end')
+  this.ws.close()
 }

package.json

 {
   "name": "websocket-stream",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "_npmUser": {
@@ -5,0 +5,0 @@ "name": "maxogden",

No alert changes

Improved metrics

Total package byte prevSize

39621

increased by0.48%

Lines of code

1212

increased by0.33%

No dependency changes