Pipes.IOStream

IStream and OStream

data IStream a

data OStream a

Convert between IOStreams and pipes

mkIStream :: Producer a IO () -> IO (IStream a)

mkOStream :: Consumer a IO () -> IO (OStream a)

fromIStream :: IStream a -> IO (Producer a IO ())

fromOStream :: OStream a -> IO (Consumer a IO ())

Reading

readOne :: IStream a -> IO (Maybe a)

readWith :: IStream a -> Parser a IO r -> IO r

Wrapping

wrapIStream :: IStream a -> (Producer a IO () -> Producer b IO ()) -> IO (IStream b)

Writting

write :: OStream a -> a -> IO ()

writeProducer :: OStream a -> Producer a IO () -> IO ()

Detecting end of stream

isEnded :: OStream a -> IO Bool

Connect and resume for consumer

(>->+) :: Monad m => Producer a m x -> Consumer a m y -> m (Consumer a m y)

Pairs each await in the consumer with an yield in the producer. Returns remaining consumer.

Re-exports

type Producer b = Proxy X () () b

Producers can only yield

type Consumer a = Proxy () a () X

Consumers can only await

type Parser a m r = forall x. StateT (Producer a m x) m r

A Parser is an action that reads from and writes to a stored Producer