public async Task ConnectAsync(CancellationToken cancellationToken)
 {
     await _transport.ConnectAsync(_url, cancellationToken).ConfigureAwait(false);
 
     _ = ReceiveMessagesAsync(cancellationToken);
     _ = ProcessEventsAwaiterAsync();
 }
 
 private async Task ReceiveMessagesAsync(CancellationToken cancellationToken)
 {
     try
     {
         while (!cancellationToken.IsCancellationRequested)
         {
             var data = await _transport.ReceiveAsync(cancellationToken).ConfigureAwait(false);
 
             ProcessReceivedMessage(data);
         }
     }
     catch (Exception ex) when (ex is not OperationCanceledException)
     {
         if (_logger.IsEnabled(LogEventLevel.Error))
         {
             _logger.Error($"Couldn't process received BiDi remote message: {ex}");
         }
 
-        throw;
+        // A reception error is fatal for the connection.
+        // Trigger cancellation for all broker operations to shut down gracefully.
+        _cancellationTokenSource.Cancel();
     }
 }