diff --git a/Source/MQTTnet/Internal/MqttPacketBus.cs b/Source/MQTTnet/Internal/MqttPacketBus.cs
index 986beed0..446c26a6 100644
--- a/Source/MQTTnet/Internal/MqttPacketBus.cs
+++ b/Source/MQTTnet/Internal/MqttPacketBus.cs
@@ -99,6 +99,8 @@ namespace MQTTnet.Internal
                 // the worker back to the thread pool.
                 await _semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
             }
+            
+            cancellationToken.ThrowIfCancellationRequested();
 
             throw new InvalidOperationException("MqttPacketBus is broken.");
         }