sealed class Iteratee[F[_], E, A] extends Serializable
An iteratee processes a stream of elements of type E
and returns a value of
type F[A]
.
- F
A type constructor representing a context for effects
- E
The type of the input data
- A
The type of the calculated result
- Self Type
- Iteratee[F, E, A]
- Source
- Iteratee.scala
- See also
- Alphabetic
- By Inheritance
- Iteratee
- Serializable
- Serializable
- 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
apply(enumerator: Enumerator[F, E])(implicit F: Monad[F]): Iteratee[F, E, A]
Advance this Iteratee with the given Enumerator.
-
final
def
as[B](b: B)(implicit F: Functor[F]): Iteratee[F, E, B]
Replace the result of this Iteratee.
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
contramap[E2](f: (E2) ⇒ E)(implicit F: Functor[F]): Iteratee[F, E2, A]
Transform the inputs to this Iteratee.
-
final
def
discard(implicit F: Functor[F]): Iteratee[F, E, Unit]
Create a new Iteratee that throws away the value this one returns.
-
final
def
ensure[T](action: F[Unit])(implicit F: MonadError[F, T]): Iteratee[F, E, A]
Ensure that an action will be performed when this iteratee is done, whether or not it succeeds.
-
final
def
ensureEval[T](action: Eval[F[Unit]])(implicit F: MonadError[F, T]): Iteratee[F, E, A]
Ensure that an action will be performed when this iteratee is done, whether or not it succeeds.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
flatMap[B](f: (A) ⇒ Iteratee[F, E, B])(implicit F: Monad[F]): Iteratee[F, E, B]
Map a function returning an Iteratee over the result.
-
final
def
flatMapM[B](f: (A) ⇒ F[B])(implicit F: Monad[F]): Iteratee[F, E, B]
Map a monadic function over the result of this Iteratee.
-
final
def
fold[Z](ifCont: ((NonEmptyList[E]) ⇒ Iteratee[F, E, A]) ⇒ Z, ifDone: (A, List[E]) ⇒ Z)(implicit F: Functor[F]): F[Z]
Reduce this Iteratee to an effectful value using the given functions.
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
handleErrorWith[T](f: (T) ⇒ Iteratee[F, E, A])(implicit F: MonadError[F, T]): Iteratee[F, E, A]
If this Iteratee has failed, use the provided function to recover.
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
map[B](f: (A) ⇒ B)(implicit F: Functor[F]): Iteratee[F, E, B]
Map a function over the result of this Iteratee.
-
final
def
mapI[G[_]](f: FunctionK[F, G])(implicit arg0: Applicative[G], F: Applicative[F]): Iteratee[G, E, A]
Transform the context of this Iteratee.
-
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
run(implicit F: Monad[F]): F[A]
Run this iteratee and close the stream so that it must produce an effectful value.
- final val state: F[Step[F, E, A]]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
through[O](enumeratee: Enumeratee[F, O, E])(implicit F: Monad[F]): Iteratee[F, O, A]
Create a new Iteratee that first processes values with the given Enumeratee.
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
up[G[_]](implicit G: Applicative[G], F: Comonad[F], F0: Applicative[F]): Iteratee[G, E, A]
Lift this Iteratee into a different context.
-
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
zip[B](other: Iteratee[F, E, B])(implicit F: Applicative[F]): Iteratee[F, E, (A, B)]
Zip this Iteratee with another to create an iteratee that returns a pair of their results.