Report and propagate an unrecoverable error. Disregard the input first and then propagate the error. This error cannot be handled by enumFromCallbackCatch, although it can be cleared by checkErr.

Report and propagate a recoverable error. This error can be handled by both enumFromCallbackCatch and checkErr.

Check if an iteratee produces an error. Returns Right a if it completes without errors, otherwise Left SomeException. checkErr is useful for iteratees that may not terminate, such as Data.Iteratee.head with an empty stream.

Skip the rest of the stream

Get the stream status of an iteratee.

Lifts a monadic action and combines it with a continuation. mBind m f is the same as lift m >>= f, but does not require a Nullable constraint on the stream type.

Lifts a monadic action, ignored the result and combines it with a continuation. mBind_ m f is the same as lift m >>= f, but does not require a Nullable constraint on the stream type.

Lifts an IO action and combines it with a continuation. ioBind m f is the same as liftIO m >>= f, but does not require a Nullable constraint on the stream type.

Lifts an IO action, ignores its result, and combines it with a continuation. ioBind_ m f is the same as liftIO m >> f, but does not require a Nullable constraint on the stream type.

Runs an Iteratee in between an IO action to acquire a resource and one to release it. Iteratee can't be an instance of MonadMask, so bracket isn't defined for it. However, if we restrict the acquire/release actions to IO, which is the most important use case anyway, we can directly implement this weaker version.

Map a monadic function over the chunks of the stream and ignore the result. Useful for creating efficient monadic iteratee consumers, e.g.

 logger = mapChunksM_ (liftIO . putStrLn)

these can be efficiently run in parallel with other iteratees via Data.Iteratee.ListLike.zip.

A fold over chunks

Get the current chunk from the stream.

Get a list of all chunks from the stream.

Convert one stream into another with the supplied mapping function. This function operates on whole chunks at a time, contrasting to mapStream which operates on single elements.

unpacker :: Enumeratee B.ByteString [Word8] m a
unpacker = mapChunks B.unpack

Convert a stream of s to a stream of s' using the supplied function.

Convert one stream into another, not necessarily in lockstep.

The transformer mapStream maps one element of the outer stream to one element of the nested stream. The transformer below is more general: it may take several elements of the outer stream to produce one element of the inner stream, or the other way around. The transformation from one stream to the other is specified as Iteratee s m s'.

The most general stream converter. Given a function to produce iteratee transformers and an initial state, convert the stream using iteratees generated by the function while continually updating the internal state.

Collapse a nested iteratee. The inner iteratee is terminated by EOF. Errors are propagated through the result.

The stream resumes from the point of the outer iteratee; any remaining input in the inner iteratee will be lost. Differs from join in that the inner iteratee is terminated, and may have a different stream type than the result.

Lift an iteratee inside a monad to an iteratee.

Each enumerator takes an iteratee and returns an iteratee

an Enumerator is an iteratee transformer. The enumerator normally stops when the stream is terminated or when the iteratee moves to the done state, whichever comes first. When to stop is of course up to the enumerator...

Applies the iteratee to the given stream. This wraps enumEof, enumErr, and enumPure1Chunk, calling the appropriate enumerator based upon Stream.

The most primitive enumerator: applies the iteratee to the terminated stream. The result is the iteratee in the Done state. It is an error if the iteratee does not terminate on EOF.

Another primitive enumerator: tell the Iteratee the stream terminated with an error.

The pure 1-chunk enumerator

It passes a given list of elements to the iteratee in one chunk This enumerator does no IO and is useful for testing of base parsing

Enumerate chunks from a list

Checks if an iteratee has finished.

This enumerator runs the iteratee, performing any monadic actions. If the result is True, the returned iteratee is done.

Create an enumerator from a callback function

Create an enumerator from a callback function with an exception handler. The exception handler is called if an iteratee reports an exception.

Utility function for creating enumeratees. Typical usage is demonstrated by the breakE definition.

breakE
  :: (Monad m, LL.ListLike s el, NullPoint s)
  => (el -> Bool)
  -> Enumeratee s s m a
breakE cpred = eneeCheckIfDone (liftI . step)
 where
  step k (Chunk s)
      | LL.null s  = liftI (step k)
      | otherwise  = case LL.break cpred s of
        (str', tail')
          | LL.null tail' -> eneeCheckIfDone (liftI . step) . k $ Chunk str'
          | otherwise     -> idone (k $ Chunk str') (Chunk tail')
  step k stream           =  idone (k stream) stream

The same as eneeCheckIfDonePass, with one extra argument: a handler which is used to process any exceptions in a separate method.

Combine enumeration over two streams. The merging enumeratee would typically be the result of merge or mergeByChunks (see merge for example).

Combines Enumerator which produces stream of s and Enumeratee which transforms stream of s to stream of s' to into Enumerator which produces stream of s'

Combines an Enumeratee from s to s' and an Iteratee that consumes s' into an Iteratee which consumes s

Enumeratee composition Run the second enumeratee within the first. In this example, stream2list is run within the 'takeStream 10', which is itself run within 'takeStream 15', resulting in 15 elements being consumed

>>> run =<< enumPure1Chunk [1..1000 :: Int] (joinI $ (I.takeStream 15 ><> I.takeStream 10) I.stream2list)
[1,2,3,4,5,6,7,8,9,10]

enumeratee composition with the arguments flipped, see ><>

Seek to a position in the stream