diff --git a/packages/network/src/network.js b/packages/network/src/network.js index dd29c8067a62..679fd7620620 100644 --- a/packages/network/src/network.js +++ b/packages/network/src/network.js @@ -136,7 +136,7 @@ const prepareHalfConnection = (zone, { watch, allVows, finalizer }) => { return watch(innerVow, this.facets.rethrowUnlessMissingWatcher); }, async close() { - const { closed, current, conns, l, r } = this.state; + const { closed, current, conns, l, r, handlers } = this.state; if (closed) { throw Error(closed); } @@ -147,8 +147,8 @@ const prepareHalfConnection = (zone, { watch, allVows, finalizer }) => { const innerVow = watch( allVows([ finalizer.finalize(conns.get(l)), - finalizer.finalize(conns.get(r)), - // E(handlers[r]).onClose(conns.get(r), undefined, handlers[r]), + // finalizer.finalize(conns.get(r)), + E(handlers[r]).onClose(conns.get(r), undefined, handlers[r]), ]), this.facets.sinkWatcher, );