File tree Expand file tree Collapse file tree 1 file changed +8
-1
lines changed Expand file tree Collapse file tree 1 file changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -688,6 +688,13 @@ class LrsCallState {
688
688
this . sendStats ( ) ;
689
689
}
690
690
691
+ destroy ( ) {
692
+ if ( this . statsTimer ) {
693
+ this . statsTimer = clearInterval ( this . statsTimer ) ;
694
+ }
695
+ return null ;
696
+ }
697
+
691
698
private handleStreamStatus ( status : StatusObject ) {
692
699
this . client . trace (
693
700
'LRS stream ended. code=' + status . code + ' details= ' + status . details
@@ -938,7 +945,7 @@ class XdsSingleServerClient {
938
945
}
939
946
940
947
handleLrsStreamEnd ( ) {
941
- this . lrsCallState = null ;
948
+ this . lrsCallState = this . lrsCallState ? this . lrsCallState . destroy ( ) : null ;
942
949
/* The backoff timer would start the stream when it finishes. If it is not
943
950
* running, restart the stream immediately. */
944
951
if ( ! this . lrsBackoff . isRunning ( ) ) {
You can’t perform that action at this time.
0 commit comments