Comparing version 0.3.1 to 0.3.2
@@ -84,2 +84,6 @@ 'use strict'; | ||
}); | ||
transport.on('error', function (error) { | ||
_this.emit('error', error); | ||
}); | ||
return _this; | ||
@@ -86,0 +90,0 @@ } |
@@ -262,2 +262,4 @@ 'use strict'; | ||
case 0: | ||
debug('attach'); | ||
server.on('listening', _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee3() { | ||
@@ -318,21 +320,21 @@ return regeneratorRuntime.wrap(function _callee3$(_context3) { | ||
if (!server.listening) { | ||
_context5.next = 11; | ||
_context5.next = 12; | ||
break; | ||
} | ||
_context5.prev = 3; | ||
_context5.next = 6; | ||
_context5.prev = 4; | ||
_context5.next = 7; | ||
return this.open(); | ||
case 6: | ||
_context5.next = 11; | ||
case 7: | ||
_context5.next = 12; | ||
break; | ||
case 8: | ||
_context5.prev = 8; | ||
_context5.t0 = _context5['catch'](3); | ||
case 9: | ||
_context5.prev = 9; | ||
_context5.t0 = _context5['catch'](4); | ||
this.emit('error', _context5.t0); | ||
case 11: | ||
case 12: | ||
case 'end': | ||
@@ -342,3 +344,3 @@ return _context5.stop(); | ||
} | ||
}, _callee5, this, [[3, 8]]); | ||
}, _callee5, this, [[4, 9]]); | ||
})); | ||
@@ -371,3 +373,3 @@ | ||
case 0: | ||
debug('listen'); | ||
debug('connect', { context: context }); | ||
@@ -432,12 +434,14 @@ (0, _checkers.checkTransport)(transport); | ||
case 0: | ||
debug('client', { context: context }); | ||
types = this.types; | ||
transport = new _transport2.default(); | ||
_context7.next = 4; | ||
_context7.next = 5; | ||
return this.connect(transport.server, context); | ||
case 4: | ||
case 5: | ||
client = new _client2.default({ types: types, transport: transport.client }); | ||
return _context7.abrupt('return', client); | ||
case 6: | ||
case 7: | ||
case 'end': | ||
@@ -444,0 +448,0 @@ return _context7.stop(); |
{ | ||
"name": "nexus", | ||
"version": "0.3.1", | ||
"version": "0.3.2", | ||
"main": "./lib/index.js", | ||
@@ -5,0 +5,0 @@ "files": [ |
116535
3044