Value Members

1.  object syntax
   Definition Classes

   Module

2.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

3.  final def ##(): Int

   Definition Classes

   AnyRef → Any

4.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

5.  final val F: MonadError[Task, Throwable]

   Attributes

   protected

   Definition Classes

   DefaultTaskModule → Module

6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  final def bracket[R <: Closeable, A](fr: Task[R])(f: (R) ⇒ Task[A])(implicit F: MonadError[Task, Throwable]): Task[A]

   Attributes

   protected

   Definition Classes

   FileModule

8.  final def captureEffect[A](a: ⇒ A): Task[A]

   Attributes

   protected

   Definition Classes

   TaskModule → SuspendableFileModule

9.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @native() @throws( ... )

10.  final def collect[O, I](pf: PartialFunction[O, I]): Enumeratee[Task, O, I]

    Transform values using a scala.PartialFunction and drop values that aren't matched.

    Transform values using a scala.PartialFunction and drop values that aren't matched.

    Definition Classes

    EnumerateeModule

11.  final def consume[E]: Iteratee[Task, E, Vector[E]]

    An Iteratee that collects all the elements in a stream in a vector.

    An Iteratee that collects all the elements in a stream in a vector.

    Definition Classes

    IterateeModule

12.  final def consumeIn[E, C[_]](implicit C: Applicative[C], M: MonoidK[C]): Iteratee[Task, E, C[E]]

    An Iteratee that collects all the elements in a stream in a given collection type.

    An Iteratee that collects all the elements in a stream in a given collection type.

    Definition Classes

    IterateeModule

13.  final def cont[E, A](ifInput: (NonEmptyList[E]) ⇒ Iteratee[Task, E, A], ifEnd: Task[A]): Iteratee[Task, E, A]

    Create an incomplete Iteratee that will use the given function to process the next input.

    Create an incomplete Iteratee that will use the given function to process the next input.

    Definition Classes

    IterateeModule

14.  final def cross[E1, E2](e2: Enumerator[Task, E2]): Enumeratee[Task, E1, (E1, E2)]

    Transform a stream by taking the cross-product with the given Enumerator.

    Transform a stream by taking the cross-product with the given Enumerator.

    Definition Classes

    EnumerateeModule

15.  final def done[E, A](value: A): Iteratee[Task, E, A]

    Create a new completed Iteratee with the given result.

    Create a new completed Iteratee with the given result.

    Definition Classes

    IterateeModule

16.  final def drop[E](n: Long): Enumeratee[Task, E, E]

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

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

    Definition Classes

    EnumerateeModule

17.  final def dropI[E](n: Int): Iteratee[Task, E, Unit]

    An Iteratee that drops a given number of the values from a stream.

    An Iteratee that drops a given number of the values from a stream.

    Definition Classes

    IterateeModule

18.  final def dropWhile[E](p: (E) ⇒ Boolean): Enumeratee[Task, E, E]

    An Enumeratee that drops values from a stream as long as they satisfy the given predicate.

    An Enumeratee that drops values from a stream as long as they satisfy the given predicate.

    Definition Classes

    EnumerateeModule

19.  final def dropWhileI[E](p: (E) ⇒ Boolean): Iteratee[Task, E, Unit]

    An Iteratee that drops values from a stream as long as they satisfy the given predicate.

    An Iteratee that drops values from a stream as long as they satisfy the given predicate.

    Definition Classes

    IterateeModule

20.  final def dropWhileM[E](p: (E) ⇒ Task[Boolean]): Enumeratee[Task, E, E]

    An Enumeratee that drops values from a stream as long as they satisfy the given monadic predicate.

    An Enumeratee that drops values from a stream as long as they satisfy the given monadic predicate.

    Definition Classes

    EnumerateeModule

21.  final def empty[E]: Enumerator[Task, E]

    An empty enumerator.

    An empty enumerator.

    Definition Classes

    EnumeratorModule

22.  final def enumEither[E](either: Either[Throwable, E]): Enumerator[Task, E]

    An enumerator that either produces a single value or fails.

    An enumerator that either produces a single value or fails.

    Definition Classes

    EnumeratorErrorModule

23.  final def enumIndexedSeq[E](es: IndexedSeq[E], min: Int = 0, max: Int = Int.MaxValue): Enumerator[Task, E]

    An enumerator that produces values from a slice of an indexed sequence.

    An enumerator that produces values from a slice of an indexed sequence.

    Definition Classes

    EnumeratorModule

24.  final def enumIterable[E](es: Iterable[E], chunkSize: Int = defaultChunkSize): Enumerator[Task, E]

    An enumerator that produces values from an iterable collection.

    An enumerator that produces values from an iterable collection.

    Definition Classes

    EnumeratorModule

25.  final def enumList[E](es: List[E]): Enumerator[Task, E]

    An enumerator that produces values from a list.

    An enumerator that produces values from a list.

    Definition Classes

    EnumeratorModule

26.  final def enumOne[E](e: E): Enumerator[Task, E]

    An enumerator that produces a single value.

    An enumerator that produces a single value.

    Definition Classes

    EnumeratorModule

27.  final def enumStream[E](es: Stream[E], chunkSize: Int = defaultChunkSize): Enumerator[Task, E]

    An enumerator that produces values from a stream.

    An enumerator that produces values from a stream.

    Definition Classes

    EnumeratorModule

28.  final def enumVector[E](es: Vector[E]): Enumerator[Task, E]

    An enumerator that produces values from a vector.

    An enumerator that produces values from a vector.

    Definition Classes

    EnumeratorModule

29.  final def enumerate[E](xs: E*): Enumerator[Task, E]

    An enumerator that produces the given values.

    An enumerator that produces the given values.

    Definition Classes

    EnumeratorModule

30.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

31.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

32.  final def failEnumerator[E](t: Throwable): Enumerator[Task, E]

    Create a failed enumerator with the given error.

    Create a failed enumerator with the given error.

    Definition Classes

    EnumeratorErrorModule

33.  final def failIteratee[E, A](t: Throwable): Iteratee[Task, E, A]

    Create a failed iteratee with the given error.

    Create a failed iteratee with the given error.

    Definition Classes

    IterateeErrorModule

34.  final def filter[E](p: (E) ⇒ Boolean): Enumeratee[Task, E, E]

    Drop values that do not satisfy the given predicate.

    Drop values that do not satisfy the given predicate.

    Definition Classes

    EnumerateeModule

35.  final def filterM[E](p: (E) ⇒ Task[Boolean]): Enumeratee[Task, E, E]

    Drop values that do not satisfy the given monadic predicate.

    Drop values that do not satisfy the given monadic predicate.

    Definition Classes

    EnumerateeModule

36.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

37.  final def flatMap[O, I](f: (O) ⇒ Enumerator[Task, I]): Enumeratee[Task, O, I]

    Map a function returning an Enumerator over a stream and flatten the results.

    Map a function returning an Enumerator over a stream and flatten the results.

    Definition Classes

    EnumerateeModule

38.  final def flatMapM[O, I](f: (O) ⇒ Task[I]): Enumeratee[Task, O, I]

    Map a function returning a value in a context over a stream.

    Map a function returning a value in a context over a stream.

    Definition Classes

    EnumerateeModule

39.  final def fold[E, A](init: A)(f: (A, E) ⇒ A): Iteratee[Task, E, A]

    An Iteratee that folds a stream using an initial value and an accumulation function.

    An Iteratee that folds a stream using an initial value and an accumulation function.

    Definition Classes

    IterateeModule

40.  final def foldM[E, A](init: A)(f: (A, E) ⇒ Task[A]): Iteratee[Task, E, A]

    An Iteratee that folds a stream using an initial value and a monadic accumulation function.

    An Iteratee that folds a stream using an initial value and a monadic accumulation function.

    Definition Classes

    IterateeModule

41.  final def foldMap[E, A](f: (E) ⇒ A)(implicit A: Monoid[A]): Iteratee[Task, E, A]

    An Iteratee that combines values using a function to a type with a cats.Monoid instance.

    An Iteratee that combines values using a function to a type with a cats.Monoid instance.

    Definition Classes

    IterateeModule

42.  final def foldMapM[E, A](f: (E) ⇒ Task[A])(implicit A: Monoid[A]): Iteratee[Task, E, A]

    An Iteratee that combines values using an effectful function to a type with a cats.Monoid instance.

    An Iteratee that combines values using an effectful function to a type with a cats.Monoid instance.

    Definition Classes

    IterateeModule

43.  final def foldMapMOption[E, A](f: (E) ⇒ Task[A])(implicit A: Semigroup[A]): Iteratee[Task, E, Option[A]]

    An Iteratee that combines values using an effectful function to a type with a cats.Semigroup instance.

    An Iteratee that combines values using an effectful function to a type with a cats.Semigroup instance.

    Definition Classes

    IterateeModule

44.  final def foldMapOption[E, A](f: (E) ⇒ A)(implicit A: Semigroup[A]): Iteratee[Task, E, Option[A]]

    An Iteratee that combines values using a function to a type with a cats.Semigroup instance.

    An Iteratee that combines values using a function to a type with a cats.Semigroup instance.

    Definition Classes

    IterateeModule

45.  final def foreach[E](f: (E) ⇒ Unit): Iteratee[Task, E, Unit]

    An Iteratee that runs a function for its side effects.

    An Iteratee that runs a function for its side effects.

    Definition Classes

    IterateeModule

46.  final def foreachM[A](f: (A) ⇒ Task[Unit]): Iteratee[Task, A, Unit]

    An Iteratee that runs an effectful function for its side effects.

    An Iteratee that runs an effectful function for its side effects.

    Definition Classes

    IterateeModule

47.  final def generateM[E](f: Task[Option[E]]): Enumerator[Task, E]

    An enumerator that returns the result of an effectful operation until None is generated.

    An enumerator that returns the result of an effectful operation until None is generated.

    Definition Classes

    EnumeratorModule

48.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

49.  final def grouped[E](n: Int): Enumeratee[Task, E, Vector[E]]

    Split the stream into groups of a given length.

    Split the stream into groups of a given length.

    Definition Classes

    EnumerateeModule

50.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

51.  final def head[E]: Iteratee[Task, E, Option[E]]

    An Iteratee that returns the first value in a stream.

    An Iteratee that returns the first value in a stream.

    Definition Classes

    IterateeModule

52.  final def identityIteratee[E]: Iteratee[Task, E, Unit]

    An iteratee that reads nothing from a stream.

    An iteratee that reads nothing from a stream.

    Definition Classes

    IterateeModule

53.  final def injectValue[E](e: E): Enumeratee[Task, E, E]

    Inject a value into a stream.

    Inject a value into a stream.

    Definition Classes

    EnumerateeModule

54.  final def injectValues[E](es: Seq[E]): Enumeratee[Task, E, E]

    Inject zero or more values into a stream.

    Inject zero or more values into a stream.

    Definition Classes

    EnumerateeModule

55.  final def intersperse[E](delim: E): Enumeratee[Task, E, E]

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

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

    Definition Classes

    EnumerateeModule

56.  final def isEnd[E]: Iteratee[Task, E, Boolean]

    An Iteratee that checks if the stream is at its end.

    An Iteratee that checks if the stream is at its end.

    Definition Classes

    IterateeModule

57.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

58.  final def iterate[E](init: E)(f: (E) ⇒ E): Enumerator[Task, E]

    An enumerator that iteratively performs an operation and returns the results.

    An enumerator that iteratively performs an operation and returns the results.

    Definition Classes

    EnumeratorModule

59.  final def iterateM[E](init: E)(f: (E) ⇒ Task[E]): Enumerator[Task, E]

    An enumerator that iteratively performs an effectful operation and returns the results.

    An enumerator that iteratively performs an effectful operation and returns the results.

    Definition Classes

    EnumeratorModule

60.  final def iterateUntil[E](init: E)(f: (E) ⇒ Option[E]): Enumerator[Task, E]

    An enumerator that iteratively performs an operation until None is produced and returns the results.

    An enumerator that iteratively performs an operation until None is produced and returns the results.

    Definition Classes

    EnumeratorModule

61.  final def iterateUntilM[E](init: E)(f: (E) ⇒ Task[Option[E]]): Enumerator[Task, E]

    An enumerator that iteratively performs an effectful operation until None is produced and returns the results.

    An enumerator that iteratively performs an effectful operation until None is produced and returns the results.

    Definition Classes

    EnumeratorModule

62.  final def last[E]: Iteratee[Task, E, Option[E]]

    An Iteratee that returns the last value in a stream.

    An Iteratee that returns the last value in a stream.

    Definition Classes

    IterateeModule

63.  final def length[E]: Iteratee[Task, E, Long]

    An Iteratee that counts the number of values in a stream.

    An Iteratee that counts the number of values in a stream.

    Definition Classes

    IterateeModule

64.  final def liftToEnumerator[E](fe: Task[E]): Enumerator[Task, E]

    Lift an effectful value into an enumerator.

    Lift an effectful value into an enumerator.

    Definition Classes

    EnumeratorModule

65.  final def liftToIteratee[E]: LiftToIterateePartiallyApplied[E]

    Lift an effectful value into an iteratee.

    Lift an effectful value into an iteratee.

    Definition Classes

    IterateeModule

66.  final def listFiles(dir: File): Enumerator[Task, File]

    Definition Classes

    SuspendableFileModule → FileModule

67.  final def listFilesRec(dir: File): Enumerator[Task, File]

    Definition Classes

    SuspendableFileModule → FileModule

68.  final def map[O, I](f: (O) ⇒ I): Enumeratee[Task, O, I]

    Map a function over a stream.

    Map a function over a stream.

    Definition Classes

    EnumerateeModule

69.  implicit final val monixTaskMonadError: MonadError[Task, Throwable]

    Definition Classes

    MonixInstances

70.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

71.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

72.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

73.  final def peek[E]: Iteratee[Task, E, Option[E]]

    An Iteratee that returns the first value in a stream without consuming it.

    An Iteratee that returns the first value in a stream without consuming it.

    Definition Classes

    IterateeModule

74.  final def perform[E]: PerformPartiallyApplied[E]

    An enumerator that forces the evaluation of an effect when it is consumed.

    An enumerator that forces the evaluation of an effect when it is consumed.

    Definition Classes

    EnumeratorModule

75.  final def readBytes(file: File): Enumerator[Task, Array[Byte]]

    Definition Classes

    SuspendableFileModule → FileModule

76.  final def readBytesFromStream(stream: InputStream): Enumerator[Task, Array[Byte]]

    Definition Classes

    SuspendableFileModule → FileModule

77.  final def readLines(file: File): Enumerator[Task, String]

    Definition Classes

    SuspendableFileModule → FileModule

78.  final def readLinesFromStream(stream: InputStream): Enumerator[Task, String]

    Definition Classes

    SuspendableFileModule → FileModule

79.  final def readZipStreams(file: File): Enumerator[Task, (ZipEntry, InputStream)]

    Definition Classes

    SuspendableFileModule → FileModule

80.  final def remainderWithResult[O, R, I](iteratee: Iteratee[Task, O, R])(f: (R, O) ⇒ I): Enumeratee[Task, O, I]

    Run an iteratee and then use the provided function to combine the result with the remaining elements.

    Run an iteratee and then use the provided function to combine the result with the remaining elements.

    Definition Classes

    EnumerateeModule

81.  final def remainderWithResultM[O, R, I](iteratee: Iteratee[Task, O, R])(f: (R, O) ⇒ Task[I]): Enumeratee[Task, O, I]

    Run an iteratee and then use the provided effectful function to combine the result with the remaining elements.

    Run an iteratee and then use the provided effectful function to combine the result with the remaining elements.

    Definition Classes

    EnumerateeModule

82.  final def repeat[E](e: E): Enumerator[Task, E]

    An enumerator that repeats the given value indefinitely.

    An enumerator that repeats the given value indefinitely.

    Definition Classes

    EnumeratorModule

83.  final def reversed[E]: Iteratee[Task, E, List[E]]

    An Iteratee that collects all inputs in reverse order.

    An Iteratee that collects all inputs in reverse order.

    Definition Classes

    IterateeModule

84.  final def scan[O, I](init: I)(f: (I, O) ⇒ I): Enumeratee[Task, O, I]

    An Enumeratee that folds a stream and emits intermediate results.

    An Enumeratee that folds a stream and emits intermediate results.

    Definition Classes

    EnumerateeModule

85.  final def scanM[O, I](init: I)(f: (I, O) ⇒ Task[I]): Enumeratee[Task, O, I]

    An Enumeratee that folds a stream using an effectful function while emitting intermediate results.

    An Enumeratee that folds a stream using an effectful function while emitting intermediate results.

    Definition Classes

    EnumerateeModule

86.  final def sequenceI[O, I](iteratee: Iteratee[Task, O, I]): Enumeratee[Task, O, I]

    Apply the given Iteratee repeatedly.

    Apply the given Iteratee repeatedly.

    Definition Classes

    EnumerateeModule

87.  final def splitOn[E](p: (E) ⇒ Boolean): Enumeratee[Task, E, Vector[E]]

    Split the stream using the given predicate to identify delimiters.

    Split the stream using the given predicate to identify delimiters.

    Definition Classes

    EnumerateeModule

88.  final def sum[E](implicit E: Monoid[E]): Iteratee[Task, E, E]

    An Iteratee that combines values using an cats.Monoid instance.

    An Iteratee that combines values using an cats.Monoid instance.

    Definition Classes

    IterateeModule

89.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

90.  final def take[E](n: Long): Enumeratee[Task, E, E]

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

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

    Definition Classes

    EnumerateeModule

91.  final def takeI[E](n: Int): Iteratee[Task, E, Vector[E]]

    An Iteratee that returns a given number of the first values in a stream.

    An Iteratee that returns a given number of the first values in a stream.

    Definition Classes

    IterateeModule

92.  final def takeWhile[E](p: (E) ⇒ Boolean): Enumeratee[Task, E, E]

    An Enumeratee that takes values from a stream as long as they satisfy the given predicate.

    An Enumeratee that takes values from a stream as long as they satisfy the given predicate.

    Definition Classes

    EnumerateeModule

93.  final def takeWhileI[E](p: (E) ⇒ Boolean): Iteratee[Task, E, Vector[E]]

    An Iteratee that returns values from a stream as long as they satisfy the given predicate.

    An Iteratee that returns values from a stream as long as they satisfy the given predicate.

    Definition Classes

    IterateeModule

94.  final def takeWhileM[E](p: (E) ⇒ Task[Boolean]): Enumeratee[Task, E, E]

    An Enumeratee that takes values from a stream as long as they satisfy the given monadic predicate.

    An Enumeratee that takes values from a stream as long as they satisfy the given monadic predicate.

    Definition Classes

    EnumerateeModule

95.  def toString(): String

    Definition Classes

    AnyRef → Any

96.  final def uniq[E](implicit E: Eq[E]): Enumeratee[Task, E, E]

    Collapse consecutive duplicates.

    Collapse consecutive duplicates.

    Definition Classes

    EnumerateeModule

    Note

    Assumes that the stream is sorted.

97.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

98.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

99.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )

100.  def writeBytes(file: File): Iteratee[Task, Array[Byte], Unit]

     Definition Classes

     SuspendableFileModule → FileModule

101.  def writeBytesToStream(stream: OutputStream): Iteratee[Task, Array[Byte], Unit]

     Definition Classes

     SuspendableFileModule → FileModule

102.  final def writeLines(file: File): Iteratee[Task, String, Unit]

     Definition Classes

     SuspendableFileModule → FileModule

103.  final def writeLinesToStream(stream: OutputStream): Iteratee[Task, String, Unit]

     Definition Classes

     SuspendableFileModule → FileModule

104.  final def zipWithIndex[E]: Enumeratee[Task, E, (E, Long)]

     Zip with the number of elements that have been encountered.

     Zip with the number of elements that have been encountered.

     Definition Classes

     EnumerateeModule