messages method

Implementation

@override
Stream<ReceivedMessage> messages() {
  if (_controller != null) {
    return _controller!.stream;
  }

  _controller = StreamController<ReceivedMessage>.broadcast(
    onListen: _registerRoomHandler,
    onCancel: _handleCancel,
  );
  _controllerClosed = false;
  return _controller!.stream;
}