@@ -567,7 +567,7 @@ export class RealtimeHandler {
567567 * <p>If the connection is successful, this method will block on its thread while it reads the
568568 * chunk-encoded HTTP body. When the connection closes, it attempts to reestablish the stream.
569569 */
570- private async beginRealtimeHttpStream ( ) : Promise < void > {
570+ private async prepareAndBeginRealtimeHttpStream ( ) : Promise < void > {
571571 if ( ! this . checkAndSetHttpConnectionFlagIfNotRunning ( ) ) {
572572 return ;
573573 }
@@ -668,7 +668,7 @@ export class RealtimeHandler {
668668 if ( this . httpRetriesRemaining > 0 ) {
669669 this . httpRetriesRemaining -- ;
670670 await new Promise ( resolve => setTimeout ( resolve , delayMillis ) ) ;
671- await this . beginRealtimeHttpStream ( ) ;
671+ await this . prepareAndBeginRealtimeHttpStream ( ) ;
672672 } else if ( ! this . isInBackground ) {
673673 const error = ERROR_FACTORY . create ( ErrorCode . CONFIG_UPDATE_STREAM_ERROR , {
674674 originalErrorMessage :
@@ -688,9 +688,9 @@ export class RealtimeHandler {
688688 * Adds an observer to the realtime updates.
689689 * @param observer The observer to add.
690690 */
691- async addObserver ( observer : ConfigUpdateObserver ) : Promise < void > {
691+ addObserver ( observer : ConfigUpdateObserver ) : void {
692692 this . observers . add ( observer ) ;
693- await this . beginRealtime ( ) ;
693+ void this . beginRealtime ( ) ;
694694 }
695695
696696 /**
0 commit comments