From ec6a02db7c9fd3fcd499b78ac48ae5d462f850af Mon Sep 17 00:00:00 2001 From: Ivan FB <128452529+Ivansete-status@users.noreply.github.com> Date: Fri, 29 May 2026 08:37:36 +0200 Subject: [PATCH] Update channels/reliable_channel.nim Co-authored-by: NagyZoltanPeter <113987313+NagyZoltanPeter@users.noreply.github.com> --- channels/reliable_channel.nim | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/channels/reliable_channel.nim b/channels/reliable_channel.nim index c3a49a370..d21143699 100644 --- a/channels/reliable_channel.nim +++ b/channels/reliable_channel.nim @@ -137,11 +137,7 @@ proc pruneCompletedChannelReqs(self: ReliableChannel) = ## segment doesn't trigger a drop on its own — we wait until siblings ## are also accounted for, so the channel-level outcome is decided ## from a complete picture. - var ongoing: HashSet[RequestId] - for entry in self.pendingMessagingRequests: - if not entry.segmentSendState.isFinal: - ongoing.incl(entry.channelReqId) - self.pendingMessagingRequests.keepItIf(it.channelReqId in ongoing) + self.pendingMessagingRequests.keepItIf(not it.segmentSendState.isFinal()) proc onMessageSent(self: ReliableChannel, messagingReqId: RequestId) = ## Invoked from this channel's `MessageSentEvent` listener. Flips