trait EnumerateeModule[F[_]] extends AnyRef
- Self Type
- EnumerateeModule[F] with Module[F]
- Source
- EnumerateeModule.scala
- Grouped
- Alphabetic
- By Inheritance
- EnumerateeModule
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
collect[O, I](pf: PartialFunction[O, I]): Enumeratee[F, O, I]
Transform values using a scala.PartialFunction and drop values that aren't matched.
-
final
def
cross[E1, E2](e2: Enumerator[F, E2]): Enumeratee[F, E1, (E1, E2)]
Transform a stream by taking the cross-product with the given Enumerator.
-
final
def
drop[E](n: Long): Enumeratee[F, E, E]
An Enumeratee that drops a given number of the first values in a stream.
-
final
def
dropWhile[E](p: (E) ⇒ Boolean): Enumeratee[F, E, E]
An Enumeratee that drops values from a stream as long as they satisfy the given predicate.
-
final
def
dropWhileM[E](p: (E) ⇒ F[Boolean]): Enumeratee[F, E, E]
An Enumeratee that drops values from a stream as long as they satisfy the given monadic predicate.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
filter[E](p: (E) ⇒ Boolean): Enumeratee[F, E, E]
Drop values that do not satisfy the given predicate.
-
final
def
filterM[E](p: (E) ⇒ F[Boolean]): Enumeratee[F, E, E]
Drop values that do not satisfy the given monadic predicate.
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
flatMap[O, I](f: (O) ⇒ Enumerator[F, I]): Enumeratee[F, O, I]
Map a function returning an Enumerator over a stream and flatten the results.
-
final
def
flatMapM[O, I](f: (O) ⇒ F[I]): Enumeratee[F, O, I]
Map a function returning a value in a context over a stream.
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
grouped[E](n: Int): Enumeratee[F, E, Vector[E]]
Split the stream into groups of a given length.
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
injectValue[E](e: E): Enumeratee[F, E, E]
Inject a value into a stream.
-
final
def
injectValues[E](es: Seq[E]): Enumeratee[F, E, E]
Inject zero or more values into a stream.
-
final
def
intersperse[E](delim: E): Enumeratee[F, E, E]
Add a value
delim
between every two items in a stream. -
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
map[O, I](f: (O) ⇒ I): Enumeratee[F, O, I]
Map a function over a stream.
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
remainderWithResult[O, R, I](iteratee: Iteratee[F, O, R])(f: (R, O) ⇒ I): Enumeratee[F, O, I]
Run an iteratee and then use the provided function to combine the result with the remaining elements.
-
final
def
remainderWithResultM[O, R, I](iteratee: Iteratee[F, O, R])(f: (R, O) ⇒ F[I]): Enumeratee[F, O, I]
Run an iteratee and then use the provided effectful function to combine the result with the remaining elements.
-
final
def
scan[O, I](init: I)(f: (I, O) ⇒ I): Enumeratee[F, O, I]
An Enumeratee that folds a stream and emits intermediate results.
-
final
def
scanM[O, I](init: I)(f: (I, O) ⇒ F[I]): Enumeratee[F, O, I]
An Enumeratee that folds a stream using an effectful function while emitting intermediate results.
-
final
def
sequenceI[O, I](iteratee: Iteratee[F, O, I]): Enumeratee[F, O, I]
Apply the given Iteratee repeatedly.
-
final
def
splitOn[E](p: (E) ⇒ Boolean): Enumeratee[F, E, Vector[E]]
Split the stream using the given predicate to identify delimiters.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
take[E](n: Long): Enumeratee[F, E, E]
An Enumeratee that takes a given number of the first values in a stream.
-
final
def
takeWhile[E](p: (E) ⇒ Boolean): Enumeratee[F, E, E]
An Enumeratee that takes values from a stream as long as they satisfy the given predicate.
-
final
def
takeWhileM[E](p: (E) ⇒ F[Boolean]): Enumeratee[F, E, E]
An Enumeratee that takes values from a stream as long as they satisfy the given monadic predicate.
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
uniq[E](implicit E: Eq[E]): Enumeratee[F, E, E]
Collapse consecutive duplicates.
Collapse consecutive duplicates.
- Note
Assumes that the stream is sorted.
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
zipWithIndex[E]: Enumeratee[F, E, (E, Long)]
Zip with the number of elements that have been encountered.