@@ -59,7 +59,7 @@ class SignalClient extends Disposable with EventsEmittable<SignalEvent> {
5959 String ? participantSid;
6060
6161 List <ConnectivityResult > _connectivityResult = [];
62- StreamSubscription <List <ConnectivityResult >>? connectivitySubscription ;
62+ StreamSubscription <List <ConnectivityResult >>? _connectivitySubscription ;
6363
6464 Future <bool > networkIsAvailable () async {
6565 // Skip check for web or flutter test
@@ -81,7 +81,8 @@ class SignalClient extends Disposable with EventsEmittable<SignalEvent> {
8181 await cleanUp ();
8282 await events.dispose ();
8383 if (! kIsWeb && ! lkPlatformIsTest ()) {
84- await connectivitySubscription? .cancel ();
84+ await _connectivitySubscription? .cancel ();
85+ _connectivitySubscription = null ;
8586 }
8687 });
8788 }
@@ -96,7 +97,8 @@ class SignalClient extends Disposable with EventsEmittable<SignalEvent> {
9697 }) async {
9798 if (! kIsWeb && ! lkPlatformIsTest ()) {
9899 _connectivityResult = await Connectivity ().checkConnectivity ();
99- connectivitySubscription = Connectivity ()
100+ await _connectivitySubscription? .cancel ();
101+ _connectivitySubscription = Connectivity ()
100102 .onConnectivityChanged
101103 .listen ((List <ConnectivityResult > result) {
102104 if (_connectivityResult != result) {
@@ -116,8 +118,6 @@ class SignalClient extends Disposable with EventsEmittable<SignalEvent> {
116118
117119 if (_connectivityResult.contains (ConnectivityResult .none)) {
118120 logger.warning ('no internet connection' );
119- events.emit (SignalDisconnectedEvent (
120- reason: DisconnectReason .noInternetConnection));
121121 throw ConnectException ('no internet connection' ,
122122 reason: ConnectionErrorReason .InternalError , statusCode: 503 );
123123 }
0 commit comments