diff --git a/packages/rstream/src/subs/sidechain-partition.ts b/packages/rstream/src/subs/sidechain-partition.ts index 1855959bfb..b48a7d67ca 100644 --- a/packages/rstream/src/subs/sidechain-partition.ts +++ b/packages/rstream/src/subs/sidechain-partition.ts @@ -64,7 +64,7 @@ export class SidechainPartition extends ASidechain { $this.dispatch($this.buf); } $this.done(); - delete $this.buf; + delete ($this).buf; }, }); } diff --git a/packages/rstream/src/subs/tunnel.ts b/packages/rstream/src/subs/tunnel.ts index 896b0ebfec..2d9dcd3e35 100644 --- a/packages/rstream/src/subs/tunnel.ts +++ b/packages/rstream/src/subs/tunnel.ts @@ -113,7 +113,7 @@ export class Tunnel extends Subscription { setTimeout(() => { LOGGER.info("terminating workers..."); this.workers.forEach((worker) => worker && worker.terminate()); - delete this.workers; + delete (this).workers; }, this.terminate); } }