braid-http
Advanced tools
Comparing version 1.3.28 to 1.3.29
@@ -1044,3 +1044,3 @@ // var peer = Math.random().toString(36).substr(2) | ||
// if we had an error, be sure to unregister ourselves | ||
await unset(e) | ||
unset(e) | ||
throw e | ||
@@ -1047,0 +1047,0 @@ } |
@@ -280,19 +280,21 @@ var assert = require('assert') | ||
// in this case, we're closing the given stream | ||
var m = braidify.multiplexers?.get(multiplexer) | ||
// if the multiplexer doesn't exist, send an error | ||
var m = braidify.multiplexers?.get(multiplexer) | ||
if (!m) { | ||
var msg = `multiplexer ${multiplexer} does not exist` | ||
res.writeHead(400, {'Content-Type': 'text/plain'}) | ||
res.end(msg) | ||
return | ||
return res.end(`multiplexer /${multiplexer} does not exist`) | ||
} | ||
// remove this stream, and notify it | ||
// if the stream doesn't exist, send an error | ||
let s = m.streams.get(stream) | ||
if (s) { | ||
s() | ||
m.streams.delete(stream) | ||
} else m.streams.set(stream, 'abort') | ||
if (!s) { | ||
res.writeHead(400, {'Content-Type': 'text/plain'}) | ||
return res.end(`stream /${multiplexer}/${stream} does not exist`) | ||
} | ||
// remove this stream, and notify it | ||
m.streams.delete(stream) | ||
s() | ||
// let the requester know we succeeded | ||
@@ -299,0 +301,0 @@ res.writeHead(200, { 'Multiplex-Version': '0.0.1' }) |
{ | ||
"name": "braid-http", | ||
"version": "1.3.28", | ||
"version": "1.3.29", | ||
"description": "An implementation of Braid-HTTP for Node.js and Browsers", | ||
@@ -5,0 +5,0 @@ "scripts": { |
81915
1582