getInRoomMessageStream method

Stream<ZegoInRoomMessage> getInRoomMessageStream({
  1. ZegoInRoomMessageType type = ZegoInRoomMessageType.broadcastMessage,
})

latest message received notifier

Implementation

Stream<ZegoInRoomMessage> getInRoomMessageStream({
  ZegoInRoomMessageType type = ZegoInRoomMessageType.broadcastMessage,
}) {
  return (type == ZegoInRoomMessageType.broadcastMessage
          ? ZegoUIKitCore.shared.coreData.broadcastMessage
              .streamControllerRemoteMessage?.stream
          : ZegoUIKitCore.shared.coreData.barrageMessage
              .streamControllerRemoteMessage?.stream) ??
      const Stream.empty();
}