diff --git a/src/Streamly/Internal/Data/Stream/Channel/Append.hs b/src/Streamly/Internal/Data/Stream/Channel/Append.hs index 387599091..a8cd3d821 100644 --- a/src/Streamly/Internal/Data/Stream/Channel/Append.hs +++ b/src/Streamly/Internal/Data/Stream/Channel/Append.hs @@ -491,10 +491,10 @@ preStopCheck sv heap = case yieldRateInfo sv of Nothing -> continue Just yinfo -> do - rateOk <- + beyondRate <- isBeyondMaxRate (maxWorkerLimit sv) (workerCount sv) yinfo - if rateOk then continue else stopping + if beyondRate then stopping else continue else stopping abortExecution :: Channel m a -> Maybe WorkerInfo -> IO ()