remove alias

podraven · Feb 19, 2024 · 64f5394 · 64f5394
1 parent c049c4a
commit 64f5394
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/src/provider.ts b/src/provider.ts
@@ -10,7 +10,7 @@ import {
 } from "@firebase/firestore";
 import { collection } from "firebase/firestore";
 import * as Y from "yjs";
-import { ObservableV2 as Observable } from "lib0/observable";
+import { ObservableV2 } from "lib0/observable";
 import * as awarenessProtocol from "y-protocols/awareness";
 import { deleteInstance, initiateInstance, refreshPeers } from "./utils";
 import { WebRtc } from "./webrtc";
@@ -44,7 +44,7 @@ interface PeersRTC {
  * @param maxWaitTime maximum miliseconds to wait before sending updates to peers
  * @param maxWaitFirestoreTime miliseconds to wait before syncing this client's update to firestore
  */
-export class FireProvider extends Observable<any> {
+export class FireProvider extends ObservableV2<any> {
   readonly doc: Y.Doc;
   awareness: awarenessProtocol.Awareness;
   readonly documentPath: string;
@@ -72,7 +72,7 @@ export class FireProvider extends Observable<any> {
 
   firebaseDataLastUpdatedAt: number = new Date().getTime();
 
-  instanceConnection: Observable<any> = new Observable();
+  instanceConnection: ObservableV2<any> = new ObservableV2();
   recreateTimeout: string | number | NodeJS.Timeout;
 
   private unsubscribeData?: Unsubscribe;

diff --git a/src/webrtc.ts b/src/webrtc.ts
@@ -12,7 +12,7 @@ import {
   DocumentData,
   DocumentReference,
 } from "@firebase/firestore";
-import { ObservableV2 as Observable } from "lib0/observable";
+import { ObservableV2 } from "lib0/observable";
 import SimplePeer from "simple-peer-light";
 import {
   Uint8ArrayToBase64,
@@ -27,7 +27,7 @@ interface Parameters {
   firebaseApp: FirebaseApp;
   ydoc: Y.Doc;
   awareness: awarenessProtocol.Awareness;
-  instanceConnection: Observable<any>;
+  instanceConnection: ObservableV2<any>;
   documentPath: string;
   uid: string;
   peerUid: string;
@@ -38,10 +38,10 @@ interface Object {
   [key: string]: any;
 }
 
-export class WebRtc extends Observable<any> {
+export class WebRtc extends ObservableV2<any> {
   readonly doc: Y.Doc;
   awareness: awarenessProtocol.Awareness;
-  instanceConnection: Observable<any>;
+  instanceConnection: ObservableV2<any>;
   readonly documentPath: string;
   uid: string;
   peerUid: string;
@@ -313,12 +313,12 @@ export class WebRtc extends Observable<any> {
     this.consoleHandler("Error", error);
   };
 
-  destroy = async () => {
+  async destroy() {
     // this.consoleHandler("destroyed");
     if (this.clock) clearTimeout(this.clock);
     if (this.peer) this.peer.destroy();
     this.unsubHandshake();
     this.deleteSignals(); // Delete calls and answers
     super.destroy();
-  };
+  }
 }