reconnect method

Future<void> reconnect()

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);
  });
}