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

Implement newIODisposer and newSTMDisposer

parent 3951dfea
No related branches found
No related tags found
No related merge requests found
Pipeline #2693 passed
......@@ -33,6 +33,7 @@ module Quasar.Resources (
import Control.Concurrent.STM
import Control.Monad.Catch
import Quasar.Awaitable
import Quasar.Async.Fork
import Quasar.Async.STMHelper
import Quasar.Exceptions
import Quasar.Monad
......@@ -41,10 +42,10 @@ import Quasar.Resources.Disposer
newIODisposer :: IO () -> TIOWorker -> ExceptionChannel -> STM Disposer
newIODisposer = undefined
newIODisposer fn worker exChan = newPrimitiveDisposer (startIOThreadShortIO fn exChan) worker exChan
newSTMDisposer :: STM () -> TIOWorker -> ExceptionChannel -> STM Disposer
newSTMDisposer = undefined
newSTMDisposer fn = newIODisposer (atomically fn)
registerResource :: (Resource a, MonadQuasar m) => a -> m ()
......
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