stop method

Future<void> stop()

Implementation

Future<void> stop() async {
  final stoppedError = room._closing && room._terminalState != null
      ? room._terminalState!.messageSendError()
      : RoomServerException("Cannot send messages because messaging has been stopped");
  _messageQueueClosed = true;
  _wakeMessageQueue();
  _drainQueuedMessages(error: stoppedError);
  final sendTask = _sendTask;
  if (sendTask != null) {
    await sendTask;
  }
  _sendTask = null;
  _desiredEnabled = false;
  _clearCurrentConnectionState();
}