diff --git a/src/DotNetty.Transport/Channels/AbstractCoalescingBufferQueue.cs b/src/DotNetty.Transport/Channels/AbstractCoalescingBufferQueue.cs index cdb8d53d..2d5f6973 100644 --- a/src/DotNetty.Transport/Channels/AbstractCoalescingBufferQueue.cs +++ b/src/DotNetty.Transport/Channels/AbstractCoalescingBufferQueue.cs @@ -202,7 +202,10 @@ public bool IsEmpty() /// public void ReleaseAndFailAll(Exception cause) { - ReleaseAndCompleteAll(TaskUtil.FromException(cause)); + var failedTask = TaskUtil.FromException(cause); + //if _bufAndListenerPairs queue is empty, the task will end up unobserved + failedTask.Ignore(); + ReleaseAndCompleteAll(failedTask); } ///