feat: listener onStreamChange

orkestral · Apr 4, 2021 · 5a5a819 · 5a5a819
1 parent 9602b78
commit 5a5a819
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/src/api/layers/listener.layer.ts b/src/api/layers/listener.layer.ts
@@ -70,6 +70,7 @@ declare global {
     onStateChange: any;
     onIncomingCall: any;
     onAck: any;
+    onStreamChange: any;
   }
 }
 const callonMessage = new callbackWile();
@@ -119,6 +120,10 @@ export class ListenerLayer extends ProfileLayer {
           window.WAPI.onStateChange(window['onStateChange']);
           window['onStateChange'].exposed = true;
         }
+        if (!window['onStreamChange'].exposed) {
+          window.WAPI.onStreamChange(window['onStreamChange']);
+          window['onStreamChange'].exposed = true;
+        }
         if (!window['onAddedToGroup'].exposed) {
           window.WAPI.onAddedToGroup(window['onAddedToGroup']);
           window['onAddedToGroup'].exposed = true;
@@ -143,6 +148,20 @@ export class ListenerLayer extends ProfileLayer {
       .catch(() => {});
   }
 
+  /**
+   * @returns Returns the current state of the connection
+   */
+  public async onStreamChange(fn: (state: SocketStream) => void) {
+    this.listenerEmitter.on(ExposedFn.onStreamChange, (state: SocketStream) => {
+      fn(state);
+    });
+    return {
+      dispose: () => {
+        this.listenerEmitter.off(ExposedFn.onStreamChange, fn);
+      },
+    };
+  }
+
   /**
    * @event Listens to messages received
    * @returns Observable stream of messages