subscribe method

void subscribe()

Implementation

void subscribe() async {
  Map sub = {
    'type': 0,
    'channel': robinChannel,
    'content': {},
    'conversation_id': "",
  };
  try {
    if (rc.robinConnection!.closeCode != null) {
      throw "reconnect";
    }
    rc.robinConnection!.sink.add(json.encode(sub));
  } catch (e) {
    rc.robinConnect();
    await Future.delayed(const Duration(milliseconds: 1000), () {
      subscribe();
    });
  }
}