From 4e711b79cc363222be29276ebbca56431a020cbc Mon Sep 17 00:00:00 2001 From: Maxim Kim Date: Thu, 2 Jun 2022 15:47:56 -0700 Subject: [PATCH] observe ReleaseAndFailAll exception task --- .../Channels/AbstractCoalescingBufferQueue.cs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/DotNetty.Transport/Channels/AbstractCoalescingBufferQueue.cs b/src/DotNetty.Transport/Channels/AbstractCoalescingBufferQueue.cs index cdb8d53d7..2d5f69738 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); } ///