An Enumeratee that checks to ensure that the passed in Iteratee is not done before doing any work.
Create an Enumeratee that filters the inputs using the given predicate
Create an Enumeratee that filters the inputs using the negation of the given predicate
flatten a scala.concurrent.Future of play.api.libs.iteratee.Enumeratee] into an Enumeratee
flatten a scala.concurrent.Future of play.api.libs.iteratee.Enumeratee] into an Enumeratee
a future of enumeratee
Create an Enumeratee that groups input using the given Iteratee.
Create an Enumeratee that groups input using the given Iteratee.
This will apply that Iteratee over and over, passing the result each time as the input for the target Iteratee, until EOF is reached. For example, let's say you had an Iteratee that took a stream of characters and parsed a single line:
def takeLine = for { line <- Enumeratee.takeWhile[Char](_ != '\n') &>> Iteratee.getChunks _ <- Enumeratee.take(1) &>> Iteratee.ignore[Char] } yield line.mkString
This could be used to build an Enumeratee that converts a stream of characters into a stream of lines:
def asLines = Enumeratee.grouped(takeLine)Create an Enumeratee which transforms its input using a given function
Create an Enumeratee that transforms its input elements into a sequence of input elements for the target Iteratee.
Create an enumeratee that transforms its input into a sequence of inputs for the target iteratee.
Create an Enumeratee that transforms its input elements into an Enumerator that is fed into the target Iteratee.
Create an Enumeratee that transforms its input using the given function.
Create an Enumeratee that transforms its input using the given function.
This is like the map function, except that it allows the Enumeratee to, for example, send EOF to the inner
iteratee before EOF is encountered.
Create an Enumeratee that transforms its input into an Enumerator that is fed into the target Iteratee.
Like mapInput, but allows the map function to asynchronously return the mapped input.
Like map, but allows the map function to asynchronously return the mapped element.
Create an Enumeratee that will take count input elements to pass to the target Iteratee, and then be done
Create an Enumeratee that will take count input elements to pass to the target Iteratee, and then be done
The number of elements to take
Create an Enumeratee that zips two Iteratees together.
Create an Enumeratee that zips two Iteratees together.
Each input gets passed to each Iteratee, and the result is a tuple of both of their results.
If either Iteratee encounters an error, the result will be an error.
The Enumeratee will continue consuming input until both inner Iteratees are done. If one inner Iteratee finishes before the other, the result of that Iteratee is held, and the one continues by itself, until it too is finished.
Create an Enumeratee that zips two Iteratees together, using the passed in zipper function to combine the results of the two.