diff --git a/NEventSocket/Sockets/ObservableSocket.cs b/NEventSocket/Sockets/ObservableSocket.cs
index be8e0fc..0b1fc26 100644
--- a/NEventSocket/Sockets/ObservableSocket.cs
+++ b/NEventSocket/Sockets/ObservableSocket.cs
@@ -126,6 +126,19 @@ void SubscriberAdded()
                             SafeLog(LogLevel.Error, "Socket Error reading from stream", ex);
                                 subject.OnError(ex);
                         }
+                        catch (OperationCanceledException ex)
+                        {
+                            if (ex.CancellationToken.IsCancellationRequested)
+                            {
+                                subject.OnCompleted();
+                            }
+                            else
+                            {
+                                SafeLog(LogLevel.Error,
+                                        "OperationCancelled not Requested by app", ex);
+                                subject.OnError(ex);
+                            }
+                        }
                         catch (Exception ex)
                         {
                             //unexpected error