Move setPublisher and sendAnswer retryable wrappers

GetStream · Jul 22, 2023 · e57a81a · e57a81a
1 parent d47c3c0
commit e57a81a
Showing 1 changed file with 2 additions and 14 deletions.
diff --git a/packages/client/src/StreamSfuClient.ts b/packages/client/src/StreamSfuClient.ts
@@ -201,33 +201,21 @@ export class StreamSfuClient {
   };
 
   updateSubscriptions = async (subscriptions: TrackSubscriptionDetails[]) => {
-    // TODO: retry handler lifted to Call so the state is reachable (?)
     return this.rpc.updateSubscriptions({
       sessionId: this.sessionId,
       tracks: subscriptions,
     });
   };
 
   setPublisher = async (data: Omit<SetPublisherRequest, 'sessionId'>) => {
-    // FIXME: needs to compare values to abort
-    return runWithRetry(
-      handleFalsePositiveResponse(this.rpc.setPublisher.bind(this.rpc)),
-      {
-        isRetryable: isRetryablePreset,
-      },
-    )({
+    return this.rpc.setPublisher({
       ...data,
       sessionId: this.sessionId,
     });
   };
 
   sendAnswer = async (data: Omit<SendAnswerRequest, 'sessionId'>) => {
-    return runWithRetry(
-      handleFalsePositiveResponse(this.rpc.sendAnswer.bind(this.rpc)),
-      {
-        isRetryable: isRetryablePreset,
-      },
-    )({
+    return this.rpc.sendAnswer({
       ...data,
       sessionId: this.sessionId,
     });