fix

lib/baseconnection.ts

@@ -19,7 +19,7 @@ export abstract class BaseConnection extends EventEmitter {
 
   constructor(
     readonly peer: string,
-    readonly provider: Peer,
+    public provider: Peer,
     readonly options: any
   ) {
     super();

lib/dataconnection.ts

@@ -173,6 +173,20 @@ export class DataConnection extends BaseConnection {
       this._negotiator = null;
     }
 
+    if (this.provider) {
+      const connections = this.provider.connections[this.peer];
+
+      if (connections) {
+        const index = connections.indexOf(this);
+
+        if (index !== -1) {
+          connections.splice(index, 1);
+        }
+      }
+
+      this.provider = null;
+    }
+
     if (!this.open) {
       return;
     }

lib/mediaconnection.ts

@@ -75,10 +75,8 @@ export class MediaConnection extends BaseConnection {
       return;
     }
 
-    this.options._payload._stream = stream;
-
     this._localStream = stream;
-    this._negotiator.startConnection(this.options._payload);
+    this._negotiator.startConnection({ ...this.options._payload, _stream: stream });
     // Retrieve lost messages stored because PeerConnection not set up.
     const messages = this.provider._getMessages(this.connectionId);
 
@@ -100,6 +98,27 @@ export class MediaConnection extends BaseConnection {
       this._negotiator = null;
     }
 
+    this._localStream = null;
+    this._remoteStream = null;
+
+    if (this.provider) {
+      const connections = this.provider.connections[this.peer];
+
+      if (connections) {
+        const index = connections.indexOf(this);
+
+        if (index !== -1) {
+          connections.splice(index, 1);
+        }
+      }
+
+      this.provider = null;
+    }
+
+    if (this.options && this.options._stream) {
+      this.options._stream = null;
+    }
+
     if (!this.open) {
       return;
     }