Skip to content
Snippets Groups Projects
Commit 48636cdd authored by Jens Nolte's avatar Jens Nolte
Browse files

Inline code from where

parent 78e8a14f
No related branches found
No related tags found
No related merge requests found
Pipeline #2710 passed
......@@ -51,10 +51,8 @@ forkAsyncWithUnmaskSTM fn worker exChan = join <$> startShortIOSTM (forkAsyncWit
-- * Fork in ShortIO (with ExceptionChannel)
forkWithUnmaskShortIO :: ((forall a. IO a -> IO a) -> IO ()) -> ExceptionChannel -> ShortIO ThreadId
forkWithUnmaskShortIO fn exChan = forkFn
forkWithUnmaskShortIO fn exChan = mask_ $ forkIOWithUnmaskShortIO wrappedFn
where
forkFn :: ShortIO ThreadId
forkFn = mask_ $ forkIOWithUnmaskShortIO wrappedFn
wrappedFn :: (forall a. IO a -> IO a) -> IO ()
wrappedFn unmask = fn unmask `catchAll` \ex -> atomically (throwToExceptionChannel exChan ex)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment