reconnect method
Implementation
Future<void> reconnect() {
return Future.delayed(Duration(milliseconds: _reconnectTimeWait), () {
_statusCallback(Status.RECONNECTING, null);
_peeked = false;
_pongCompleter = Completer.sync()
..future.then((_) {
final proto = StringBuffer();
for (Subscription s in subs.values) {
proto.write('SUB ${s.subject} ${s.sid}\r\n');
}
send(utf8.encode(proto.toString()));
_reconnectAttempts = 0;
});
connect(_servers);
});
}