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