close method

  1. @override
void close()
override

Close the transport

Implementation

@override
void close() {
  if (_isClosed) return;
  _isClosed = true;

  _logger.debug('Closing SseAuthClientTransport');

  // Cancel token refresh timer
  _tokenRefreshTimer?.cancel();

  // Close event source
  _eventSource.close();

  // Close streams
  if (!_messageController.isClosed) {
    _messageController.close();
  }
  if (!_closeCompleter.isCompleted) {
    _closeCompleter.complete();
  }
}