diff --git a/src/Quasar/Awaitable.hs b/src/Quasar/Awaitable.hs index 69afe39ff63100d252821b171a4539bdb03d9201..a595221e601880c5b3c2ee815d95ca7e3adbaba7 100644 --- a/src/Quasar/Awaitable.hs +++ b/src/Quasar/Awaitable.hs @@ -76,7 +76,7 @@ class Monad m => MonadAwait m where await :: IsAwaitable r a => a -> m r instance MonadAwait IO where - await = awaitIO + await awaitable = liftIO $ runQueryT atomically (runAwaitable awaitable) instance MonadAwait m => MonadAwait (ReaderT a m) where await = lift . await @@ -86,9 +86,6 @@ awaitResult :: (IsAwaitable r a, MonadAwait m) => m a -> m r awaitResult = (await =<<) -awaitIO :: (IsAwaitable r a, MonadIO m) => a -> m r -awaitIO awaitable = liftIO $ runQueryT atomically (runAwaitable awaitable) - peekAwaitable :: (IsAwaitable r a, MonadIO m) => a -> m (Maybe (Either SomeException r)) peekAwaitable awaitable = liftIO $ runMaybeT $ try $ runQueryT queryFn (runAwaitable awaitable) where