Example of Publisher Retry logic

publisher.js

let currentRetryAttempt = 0;
const maxRetryAttempts = 3;
const retryAttemptTimeout = 1000;

function handleRetryPublisher() {
    setTimeout(() => {
      currentRetryAttempt += 1;
      this.createPublisher();
    }, this.retryAttemptTimeout);
}

function createPublisher(){
  const publisher = OT.initPublisher(stream,
            "container",
            {...options},
            (err) => {
              
              if (err && currentRetryAttempt < (this.maxRetryAttempts - 1)) {
                // Error during subscribe function
                this.handleRetryPublisher();
                // If there is a retry action, do we want to execute the onError props function?
                // return;
              } else if (err) {
                // Retry attempts finished. Show an Error message to the User
              } else if (!err ) {
                // Published!
              }
            },
        );
}

subscriber.js

let currentRetryAttempt = 0;
const maxRetryAttempts = 3;
const retryAttemptTimeout = 1000;
const session, stream;

function handleRetrySubscriber() {
    setTimeout(() => {
      currentRetryAttempt += 1;
      this.subscribeToStream();
    }, this.retryAttemptTimeout);
}

function subscribeToStream(){
  const subscriber = session.subscribe(stream,
            "container",
            {...options},
            (err) => {
              
              if (err && currentRetryAttempt < (this.maxRetryAttempts - 1)) {
                // Error during subscribe function
                this.handleRetrySubscriber();
                
                // return;
              } else if (err) {
                // Retry attempts finished. Show an Error message to the User
              } else if (!err ) {
                // subscribed!
              }
            },
        );
}