Documentation

data TQueue a Source #

newIO :: forall a m. MonadIO m => m (TQueue a) Source #

size :: TQueue a -> STM Int Source #

awaitSize :: Int -> TQueue a -> STM () Source #

peek :: TQueue a -> STM a Source #

dequeue :: TQueue a -> STM a Source #

undequeue :: TQueue a -> a -> STM () Source #

tryDequeue :: TQueue a -> STM (Maybe a) Source #

dequeueN :: TQueue a -> Int -> STM [a] Source #

enqueueCount :: TQueue a -> STM Word64 Source #

flush :: TQueue a -> STM [a] Source #

enqueue :: TQueue a -> a -> STM () Source #

raceIO :: MonadIO m => STM a -> STM b -> m (Either a b) Source #

tryPeekWhile :: (a -> Bool) -> TQueue a -> STM [a] Source #

takeWhile :: (a -> Bool) -> TQueue a -> STM [a] Source #

peekWhile :: (a -> Bool) -> TQueue a -> STM [a] Source #