use arrow functions to not lose context for this

Author: yaacovCR

src/execution/publisher.ts

@@ -70,21 +70,20 @@ export class Publisher<TSource extends Source, TIncremental, TPayload> {
 
   subscribe(): AsyncGenerator<TPayload, void, void> {
     let isDone = false;
-    const publisher = this;
 
-    async function next(): Promise<IteratorResult<TPayload, void>> {
+    const next = async (): Promise<IteratorResult<TPayload, void>> => {
       if (isDone) {
         return { value: undefined, done: true };
       }
 
-      await Promise.race(Array.from(publisher.sources).map((p) => p.promise));
+      await Promise.race(Array.from(this.sources).map((p) => p.promise));
 
       if (isDone) {
         return { value: undefined, done: true };
       }
 
-      const incremental = publisher.getCompletedIncrementalResults();
-      const hasNext = publisher.sources.size > 0;
+      const incremental = this.getCompletedIncrementalResults();
+      const hasNext = this.sources.size > 0;
 
       if (!incremental.length && hasNext) {
         return next();
@@ -95,20 +94,20 @@ export class Publisher<TSource extends Source, TIncremental, TPayload> {
       }
 
       return {
-        value: publisher.toPayload(incremental, hasNext),
+        value: this.toPayload(incremental, hasNext),
         done: false,
       };
-    }
+    };
 
-    function returnIterators() {
+    const returnIterators = () => {
       const promises: Array<Promise<IteratorResult<unknown>>> = [];
-      publisher.sources.forEach((source) => {
+      this.sources.forEach((source) => {
         if (source.iterator?.return) {
           promises.push(source.iterator.return());
         }
       });
       return Promise.all(promises);
-    }
+    };
 
     return {
       [Symbol.asyncIterator]() {