This module provide different utility functions that allow to use safe higher level usage.

Conduit pairs allow creation of an internal datastructure that acts as a bridge, and provides input and output conduits. The structure itself is hidden internally and can't be used directly, this provide an additional safeness.

In order to create a bridge from your own datastructures you need to do the following:

• Make it an instance of UnboundedStream or BoundedStream depending on it's properties:

instance BoundedStream (Proxy2 TBMQueue) TBMQueue where
 mkBStream _ i = atomically $ newTBMQueue i

• Add IsConduit instance.

 instance MonadIO m => IsConduit m TBMQueue where
   mkSource = sourceTBMQueue
   mkSink   = flip sinkTBMQueue True

• Use "pair" or "pairBounded" to create a bridge. Because bridge data structure is hidden and not seen in parameters, we need proxy type to help compiler to choose type, we use Proxy2 for that.

 pairTBMQueue = pairBounded (proxy2 :: Proxy2 TBMQueue a)

• Now we can create a pair of conduits:

(src, snk) <- pairTBMQueue 32
Control.Concurrent.Async.concurrently (sender src) (receviver snk)

As channel is not visible we can close it or send additional messages bypassing conduit code.

This package provides predefined pairs for all STM types that are used in the package.

List of specialized functions, that can create a bridges over STM types, where *B* stands for bounded *M* stands for closable. If data structure is not closable then there is no way to notify receiver side that bridge is closed, so it's possible to use it only in infinite streams of when some other mechanism of notification is used.