refactor Multicast

packages/channels/generators.js

@@ -68,23 +68,24 @@ export function multicast(iterator) {
 }
 
 export class Multicast {
-    consumers = [];
+    #consumers = [];
+
     constructor(subject) {
         this.subject = subject;
         this.#start();
     }
 
     async #start() {
         for await(let value of this.subject) {
-            for(let consumer of this.consumers) {
+            for(let consumer of this.#consumers) {
                 consumer(value);
             }
         }
     }
 
     subscriber(transform, options) {
         const [iterator, dispatch] = subject(transform, options);
-        this.consumers.push(dispatch);
+        this.#consumers.push(dispatch);
         return iterator;
     }
 }