@@ -118,8 +118,7 @@ export class RealtimeHandler {
118
118
const currentTime = Date . now ( ) ;
119
119
const backoffDurationInMillis = retryIntervalSeconds * 1000 ;
120
120
const backoffEndTime = new Date ( currentTime + backoffDurationInMillis ) ;
121
- const numFailedStreams =
122
- ( await this . storage . getRealtimeBackoffMetadata ( ) ) ?. numFailedStreams || 0 ;
121
+ const numFailedStreams = 0 ;
123
122
await this . storage . setRealtimeBackoffMetadata ( {
124
123
backoffEndTimeMillis : backoffEndTime ,
125
124
numFailedStreams
@@ -159,7 +158,7 @@ export class RealtimeHandler {
159
158
} catch ( e ) {
160
159
// The network connection was lost, so cancel() failed.
161
160
// This is expected in a disconnected state, so we can safely ignore the error.
162
- this . logger . debug ( 'Failed to cancel the reader, connection is gone .' ) ;
161
+ this . logger . debug ( 'Failed to cancel the reader, connection was lost .' ) ;
163
162
} finally {
164
163
this . reader = undefined ;
165
164
}
@@ -550,7 +549,7 @@ export class RealtimeHandler {
550
549
await this . handleNotifications ( reader ) ;
551
550
} catch ( e ) {
552
551
// If the real-time connection is at an unexpected lifecycle state when the app is
553
- // backgrounded, it's expected closing the connection and will throw an exception.
552
+ // backgrounded, it's expected closing the connection will throw an exception.
554
553
if ( ! this . isInBackground ) {
555
554
// Otherwise, the real-time server connection was closed due to a transient issue.
556
555
this . logger . debug (
@@ -588,7 +587,6 @@ export class RealtimeHandler {
588
587
let response : Response | undefined ;
589
588
let responseCode : number | undefined ;
590
589
try {
591
- //this has been called in the try cause it throws an error if the method does not get implemented
592
590
response = await this . createRealtimeConnection ( ) ;
593
591
responseCode = response . status ;
594
592
if ( response . ok && response . body ) {
0 commit comments