common: simplify some socket utils

koush · Mar 28, 2023 · f55cc60 · f55cc60
1 parent 8a1633f
commit f55cc60
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/common/src/ffmpeg-rebroadcast.ts b/common/src/ffmpeg-rebroadcast.ts
@@ -361,8 +361,7 @@ export interface RebroadcasterOptions {
     },
 }
 
-export async function handleRebroadcasterClient(duplex: Promise<Duplex> | Duplex, options?: RebroadcasterOptions) {
-    const socket = await duplex;
+export function handleRebroadcasterClient(socket: Duplex, options?: RebroadcasterOptions) {
     const firstWriteData = (data: StreamChunk) => {
         if (data.startStream) {
             socket.write(data.startStream)

diff --git a/common/src/listen-cluster.ts b/common/src/listen-cluster.ts
@@ -62,4 +62,4 @@ export async function bind(server: dgram.Socket, port: number) {
     }
 }
 
-export { listenZero, listenZeroSingleClient } from "@scrypted/server/src/listen-zero";
+export { listenZero, listenZeroSingleClient, ListenZeroSingleClientTimeoutError } from "@scrypted/server/src/listen-zero";
-Original file line number
+Diff line change
@@ Expand Up @@
         }
     }
-    export { listenZero, listenZeroSingleClient } from "@scrypted/server/src/listen-zero";
+    export { listenZero, listenZeroSingleClient, ListenZeroSingleClientTimeoutError } from "@scrypted/server/src/listen-zero";