joinThisRoom method
连接聊天服务器
Implementation
void joinThisRoom(String me) {
socks = ChannelService(roomId, me);
connected = true;
socks.lookingForMessage((String msgStr) {
// TODO: 获取到了新的消息
final map = jsonDecode(msgStr);
if (map.containsKey('error')) {
messageStreamController.sink.add(0);
return leaveThisRoom();
}
final ev = MessageEvent.fromMap(map);
messages.add(ev.message);
messageStreamController.sink.add(1);
});
}