Packages

t

io.iteratee

EnumerateeModule

trait EnumerateeModule[F[_]] extends AnyRef

Ordering
  1. Grouped
  2. Alphabetic
  3. By Inheritance
Inherited
  1. EnumerateeModule
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. 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.

  7. 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.

  8. final def drop[E](n: Long): Enumeratee[F, E, E]

    An Enumeratee that drops a given number of the first values in a stream.

  9. 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.

  10. 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.

  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  13. final def filter[E](p: (E) ⇒ Boolean): Enumeratee[F, E, E]

    Drop values that do not satisfy the given predicate.

  14. final def filterM[E](p: (E) ⇒ F[Boolean]): Enumeratee[F, E, E]

    Drop values that do not satisfy the given monadic predicate.

  15. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. 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.

  17. 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.

  18. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  19. final def grouped[E](n: Int): Enumeratee[F, E, Vector[E]]

    Split the stream into groups of a given length.

  20. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  21. final def injectValue[E](e: E): Enumeratee[F, E, E]

    Inject a value into a stream.

  22. final def injectValues[E](es: Seq[E]): Enumeratee[F, E, E]

    Inject zero or more values into a stream.

  23. final def intersperse[E](delim: E): Enumeratee[F, E, E]

    Add a value delim between every two items in a stream.

  24. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  25. final def map[O, I](f: (O) ⇒ I): Enumeratee[F, O, I]

    Map a function over a stream.

  26. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  27. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  28. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  29. 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.

  30. 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.

  31. 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.

  32. 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.

  33. final def sequenceI[O, I](iteratee: Iteratee[F, O, I]): Enumeratee[F, O, I]

    Apply the given Iteratee repeatedly.

  34. final def splitOn[E](p: (E) ⇒ Boolean): Enumeratee[F, E, Vector[E]]

    Split the stream using the given predicate to identify delimiters.

  35. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  36. final def take[E](n: Long): Enumeratee[F, E, E]

    An Enumeratee that takes a given number of the first values in a stream.

  37. 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.

  38. 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.

  39. def toString(): String
    Definition Classes
    AnyRef → Any
  40. 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.

  41. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  42. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  43. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  44. final def zipWithIndex[E]: Enumeratee[F, E, (E, Long)]

    Zip with the number of elements that have been encountered.

Inherited from AnyRef

Inherited from Any

Enumeratees

Ungrouped