diff --git a/lib/units/device/plugins/forward/util/manager.js b/lib/units/device/plugins/forward/util/manager.js index 7ecf6d5d..b38af51b 100644 --- a/lib/units/device/plugins/forward/util/manager.js +++ b/lib/units/device/plugins/forward/util/manager.js @@ -117,6 +117,7 @@ util.inherits(ForwardHandler, events.EventEmitter) function DestHandler(id, conn, options) { function endListener() { conn.removeListener('drain', drainListener) + writer.removeListener('readable', readableListener) this.emit('end') }