joinThisRoom method

void joinThisRoom(
  1. String me
)

连接聊天服务器

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