Removed opaque type for chan dupping.

Author: lukehoersten

src/System/IO/Streams/Concurrent/Unagi/Bounded.hs

@@ -6,26 +6,21 @@ module System.IO.Streams.Concurrent.Unagi.Bounded
  , chanToInput
  , chanToOutput
  , makeChanPipe
- , dupStream
- , DupHandle
  ) where
 
 
 ------------------------------------------------------------------------------
-import Control.Applicative (pure, (<$>), (<*>))
+import Control.Applicative ((<$>), (<*>))
 import Control.Concurrent.Chan.Unagi.Bounded (InChan, OutChan,
- dupChan, newChan,
- readChan, writeChan)
-import Control.Monad ((>=>))
+ newChan, readChan,
+ writeChan)
 import Prelude hiding (read)
 import System.IO.Streams.Internal (InputStream,
  OutputStream,
  makeInputStream,
  makeOutputStream, read)
 
 
-newtype DupHandle a = DupHandle { unDupHandle :: InChan (Maybe a) }
-
 ------------------------------------------------------------------------------
 -- | Writes the contents of an input stream to a channel until the input stream
 -- yields end-of-stream.
@@ -58,15 +53,7 @@ chanToOutput = makeOutputStream . writeChan
 --
 -- Since reading from the 'InputStream' and writing to the 'OutputStream' are
 -- blocking calls, be sure to do so in different threads.
-makeChanPipe :: Int -> IO (InputStream a, OutputStream a, DupHandle a)
+makeChanPipe :: Int -> IO (InputStream a, OutputStream a)
 makeChanPipe size = do
  (inChan, outChan) <- newChan size
- (,,) <$> chanToInput outChan <*> chanToOutput inChan <*> pure (DupHandle inChan)
-
-
-------------------------------------------------------------------------------
--- | Use a 'DupHandle' to replicate everything written on the
--- associated 'OutputStream' to the 'InputStream'.
---
-dupStream :: DupHandle a -> IO (InputStream a)
-dupStream = dupChan . unDupHandle >=> chanToInput
+ (,) <$> chanToInput outChan <*> chanToOutput inChan

unagi-streams.cabal

@@ -21,5 +21,6 @@ library
  , unagi-chan >= 0.2 && < 0.3
  , io-streams >= 1.2 && < 1.3
 
- hs-source-dirs: src/
+
+ hs-source-dirs: src
  default-language: Haskell2010