This commit is contained in:
Dmitry Zuikov 2024-04-10 11:30:53 +03:00
parent c75dd1ae6b
commit c19956a73a
1 changed files with 1 additions and 3 deletions

View File

@ -314,14 +314,12 @@ mainLoop = do
r <- liftIO $ E.try @SomeException (join $ atomically $ readTQueue jobs) r <- liftIO $ E.try @SomeException (join $ atomically $ readTQueue jobs)
case r of case r of
Left e -> do Left e -> do
err ("CATCHED" <+> viaShow e) err (viaShow e)
let ee = fromException @AsyncCancelled e let ee = fromException @AsyncCancelled e
unless (isJust ee) do unless (isJust ee) do
next next
debug "WE'RE FUCKING CANCELLED!"
_ -> next _ -> next
void $ waitAnyCatchCancel [p1,p2,p3] void $ waitAnyCatchCancel [p1,p2,p3]