mirror of
https://github.com/composewell/streamly.git
synced 2024-10-05 15:29:09 +03:00
Fix rate control in preStopCheck of ordered stream worker
This commit is contained in:
parent
15418a8f2c
commit
f65996aabe
@ -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 ()
|
||||
|
Loading…
Reference in New Issue
Block a user