roomMessageStream method

Stream<int> roomMessageStream(
  1. String roomId
)

监听消息流，返回0表示应该中断流

Implementation

Stream<int> roomMessageStream(String roomId) {
  print(chatRoom.rooms.map((e) => e.roomId).toList().toString());
  return chatRoom.rooms
      .where((element) => element.roomId == roomId)
      .first
      .messageStreamController
      .stream;
}