close method

  1. @override
Future<void> close()
override

Closes the connection.

Implementation

@override
Future<void> close() async {
  if (_isClosed) {
    throw const PusherChannelsWebSocketConnectionWasClosedException();
  }
  _isClosed = true;
  await _webSocketEventsSubscription?.cancel();
  await _webSocketChannel?.sink.close();
}