module Control.Concurrent.FiniteChan (
Chan,
newChan, dupChan, putChan, getChan, readChan, closeChan, stopChan
) where
import qualified Control.Concurrent.Chan as C
import Data.Maybe
newtype Chan a = Chan (C.Chan (Maybe a))
newChan :: IO (Chan a)
newChan = fmap Chan C.newChan
dupChan :: Chan a -> IO (Chan a)
dupChan (Chan ch) = fmap Chan $ C.dupChan ch
putChan :: Chan a -> a -> IO ()
putChan (Chan ch) = C.writeChan ch . Just
getChan :: Chan a -> IO (Maybe a)
getChan (Chan ch) = C.readChan ch
readChan :: Chan a -> IO [a]
readChan (Chan ch) = fmap (catMaybes . takeWhile isJust) $ C.getChanContents ch
closeChan :: Chan a -> IO ()
closeChan (Chan ch) = C.writeChan ch Nothing
stopChan :: Chan a -> IO [a]
stopChan ch = closeChan ch >> readChan ch