{-# LANGUAGE UnicodeSyntax #-}
{-# LANGUAGE FlexibleContexts #-}
module Control.Concurrent.STM.TQueue.Lifted
( TQueue
, newTQueue
, newTQueueIO
, readTQueue
, tryReadTQueue
, peekTQueue
, tryPeekTQueue
, flushTQueue
, writeTQueue
, unGetTQueue
, isEmptyTQueue
) where
import Control.Monad.Base (MonadBase(..))
import Control.Monad.STM (STM)
import Control.Concurrent.STM.TQueue (TQueue)
import qualified Control.Concurrent.STM.TQueue as STM
newTQueue ∷ MonadBase STM μ ⇒ μ (TQueue α)
newTQueue = liftBase STM.newTQueue
{-# INLINE newTQueue #-}
newTQueueIO ∷ MonadBase IO μ ⇒ μ (TQueue α)
newTQueueIO = liftBase STM.newTQueueIO
{-# INLINE newTQueueIO #-}
readTQueue ∷ MonadBase STM μ ⇒ TQueue α → μ α
readTQueue = liftBase . STM.readTQueue
{-# INLINE readTQueue #-}
tryReadTQueue ∷ MonadBase STM μ ⇒ TQueue α → μ (Maybe α)
tryReadTQueue = liftBase . STM.tryReadTQueue
{-# INLINE tryReadTQueue #-}
peekTQueue ∷ MonadBase STM μ ⇒ TQueue α → μ α
peekTQueue = liftBase . STM.peekTQueue
{-# INLINE peekTQueue #-}
tryPeekTQueue ∷ MonadBase STM μ ⇒ TQueue α → μ (Maybe α)
tryPeekTQueue = liftBase . STM.tryPeekTQueue
{-# INLINE tryPeekTQueue #-}
flushTQueue ∷ MonadBase STM μ ⇒ TQueue α → μ [α]
flushTQueue = liftBase . STM.flushTQueue
{-# INLINE flushTQueue #-}
writeTQueue ∷ MonadBase STM μ ⇒ TQueue α → α → μ ()
writeTQueue = (liftBase .) . STM.writeTQueue
{-# INLINE writeTQueue #-}
unGetTQueue ∷ MonadBase STM μ ⇒ TQueue α → α → μ ()
unGetTQueue = (liftBase .) . STM.unGetTQueue
{-# INLINE unGetTQueue #-}
isEmptyTQueue ∷ MonadBase STM μ ⇒ TQueue α → μ Bool
isEmptyTQueue = liftBase . STM.isEmptyTQueue
{-# INLINE isEmptyTQueue #-}