Skip to content
This repository has been archived by the owner on Feb 7, 2022. It is now read-only.

Commit

Permalink
Merge pull request #4 from bobagold/bugfix/reconnect
Browse files Browse the repository at this point in the history
Bugfix/reconnect
  • Loading branch information
haoguo committed Jun 16, 2019
2 parents f5824b1 + b26e49a commit f85bfea
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions lib/ddp_client.dart
Expand Up @@ -153,7 +153,7 @@ class DdpClient implements ConnectionNotifier, StatusNotifier {
Message.method(call.id, call.serviceMethod, call.args).toJson()));
this._subs.values.forEach((call) => this
.send(Message.sub(call.id, call.serviceMethod, call.args).toJson()));
}).catchError(() {
}).catchError((error) {
this.close();
this._reconnectLater();
});
Expand Down Expand Up @@ -353,7 +353,7 @@ class DdpClient implements ConnectionNotifier, StatusNotifier {
this._collections.values.forEach((c) => c._init());
this._version = '1';
this._session = msg['session'] as String;
this._pingTimer = Timer(this.heartbeatInterval, () {
this._pingTimer = Timer.periodic(this.heartbeatInterval, (Timer timer) {
this.ping();
});
this._connectionListener.forEach((l) => l());
Expand Down

0 comments on commit f85bfea

Please sign in to comment.