Writes the contents of an input stream to a channel until the input stream yields end-of-stream.
Moduleio-streams-1.5.2.2Haskell2010
System.IO.Streams.Concurrent
Stream utilities for working with concurrent channels.
Contents
Synopsis
- value inputToChan
- value chanToInput
- value chanToOutput
- value concurrentMerge
- value makeChanPipe
- Packageio-streams-1.5.2.2
- Exports5
- LanguageHaskell2010
- LicenceBSD-3-Clause
- SourceConcurrent.hs
Channel conversions
Turns a Chan into an input stream.
Turns a Chan into an output stream.
Concurrently merges a list of InputStreams, combining values in the order they become available.
Note: does not forward individual end-of-stream notifications, the produced stream does not yield end-of-stream until all of the input streams have finished.
Any exceptions raised in one of the worker threads will be trapped and re-raised in the current thread.
If the supplied list is empty, concurrentMerge will return an empty stream. (Since: 1.5.0.1)
Create a new pair of streams using an underlying Chan. Everything written to the OutputStream will appear as-is on the InputStream.
Since reading from the InputStream and writing to the OutputStream are blocking calls, be sure to do so in different threads.