Packages

object IterantRunner

Linear Supertypes
AnyRef, Any
Content Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. IterantRunner
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. case class Ack[A, M](req: Request[M], unfinished: Task[A]) extends Output[A, M] with Product with Serializable
  2. case class Command[M](command: M) extends Request[M] with Product with Serializable
  3. case class Halt[M]() extends Request[M] with Product with Serializable
  4. case class Halted[S, M](state: S) extends State[S, M] with Product with Serializable
  5. sealed trait Output[A, M] extends AnyRef
  6. sealed trait Request[M] extends AnyRef
  7. case class Result[A, M](result: A) extends Output[A, M] with Product with Serializable
  8. case class Running[S, M](state: S, pollTask: Task[Request[M]]) extends State[S, M] with Product with Serializable
  9. sealed trait State[S, M] extends AnyRef

Value Members

  1. def delayed[A, M](iter: Iterant[Task, Output[A, M]]): Iterant[Task, Output[A, M]]
  2. def resultOpt[S](iter: Iterant[Task, S], isStable: (S, S) => Boolean): Task[Option[S]]
  3. def running[S, M]: (Output[S, M]) => Boolean
  4. def tillStable[S](iter: Iterant[Task, S], isStable: (S, S) => Boolean): Iterant[Task, (Option[S], Option[S])]
  5. def withDelayed[A, M](iter: Iterant[Task, Output[A, M]]): Iterant[Task, Output[A, M]]