Update DataStreams API (#1393)

Author: lukasIO

examples/demo/demo.ts

@@ -14,7 +14,6 @@ import {
   ConnectionState,
   DisconnectReason,
   ExternalE2EEKeyProvider,
-  LocalAudioTrack,
   LogLevel,
   MediaDeviceFailure,
   Participant,
@@ -247,7 +246,7 @@ const appActions = {
         );
       });
 
-    room.setTextStreamHandler(async (reader, participant) => {
+    room.registerTextStreamHandler('chat', async (reader, participant) => {
       const info = reader.info;
       if (info.size) {
         handleChatMessage(
@@ -272,9 +271,9 @@ const appActions = {
         appendLog('text stream finished');
       }
       console.log('final info including close extensions', reader.info);
-    }, 'chat');
+    });
 
-    room.setByteStreamHandler(async (reader, participant) => {
+    room.registerByteStreamHandler('files', async (reader, participant) => {
       const info = reader.info;
 
       appendLog(`started to receive a file called "${info.name}" from ${participant?.identity}`);
@@ -340,7 +339,7 @@ const appActions = {
         downloadLink.style.display = 'block';
         $('chat-area').after(downloadLink);
       }
-    }, 'files');
+    });
 
     try {
       // read and set current key from input

src/room/Room.ts

@@ -278,25 +278,25 @@ class Room extends (EventEmitter as new () => TypedEmitter<RoomEventCallbacks>)
     }
   }
 
-  setTextStreamHandler(callback: TextStreamHandler, topic: string = '') {
+  registerTextStreamHandler(topic: string, callback: TextStreamHandler) {
     if (this.textStreamHandlers.has(topic)) {
       throw new TypeError(`A text stream handler for topic "${topic}" has already been set.`);
     }
     this.textStreamHandlers.set(topic, callback);
   }
 
-  removeTextStreamHandler(topic: string = '') {
+  unregisterTextStreamHandler(topic: string) {
     this.textStreamHandlers.delete(topic);
   }
 
-  setByteStreamHandler(callback: ByteStreamHandler, topic: string = '') {
+  registerByteStreamHandler(topic: string, callback: ByteStreamHandler) {
     if (this.byteStreamHandlers.has(topic)) {
       throw new TypeError(`A byte stream handler for topic "${topic}" has already been set.`);
     }
     this.byteStreamHandlers.set(topic, callback);
   }
 
-  removeByteStreamHandler(topic: string = '') {
+  unregisterByteStreamHandler(topic: string) {
     this.byteStreamHandlers.delete(topic);
   }