object
TaskExtra extends TaskExtra
Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
def
all[D](in: Seq[Result[D]]): Seq[D]
-
def
allM[K[L[x]]](implicit a: AList[K]): (K[Result]) ⇒ K[Types.Id]
-
def
anyFailM[K[L[x]]](implicit a: AList[K]): (K[Result]) ⇒ Seq[Incomplete]
-
final
def
asInstanceOf[T0]: T0
-
implicit final
def
binaryPipeTask[Key](in: Task[_])(implicit streams: Task[TaskStreams[Key]], key: (Task[_]) ⇒ Key): BinaryPipe
-
def
clone(): AnyRef
-
final
def
constant[T](t: T): Task[T]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
expectedFailure: Nothing
-
-
-
def
failuresM[K[L[x]]](implicit a: AList[K]): (K[Result]) ⇒ Seq[Incomplete]
-
def
finalize(): Unit
-
final
def
getClass(): Class[_]
-
def
hashCode(): Int
-
-
final
def
inlineTask[T](value: T): Task[T]
-
final
def
isInstanceOf[T0]: Boolean
-
implicit final
def
iterableTask[S](in: Seq[S]): ForkTask[S, Seq]
-
implicit final
def
joinAnyTasks(in: Seq[Task[_]]): JoinTask[Any, Seq]
-
implicit final
def
joinTasks[S](in: Seq[Task[S]]): JoinTask[S, Seq]
-
implicit final
def
linesTask[Key](in: Task[_])(implicit streams: Task[TaskStreams[Key]], key: (Task[_]) ⇒ Key): TaskLines
-
implicit final
def
multInputTask[K[L[X]]](tasks: K[Task])(implicit a: AList[K]): MultiInTask[K]
-
implicit final
def
multT2Task[A, B](in: (Task[A], Task[B])): MultiInTask[[L[x]](L[A], L[B])]
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
nop: Task[Unit]
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
implicit final
def
pipeToProcess[Key](t: Task[_])(implicit streams: Task[TaskStreams[Key]], key: (Task[_]) ⇒ Key): ProcessPipe
-
-
-
def
reducePair[S](a: Task[S], b: Task[S], f: (S, S) ⇒ S): Task[S]
-
def
reduced[S](i: IndexedSeq[Task[S]], f: (S, S) ⇒ S): Task[S]
-
implicit final
def
singleInputTask[S](in: Task[S]): SingleInTask[S]
-
def
successM[T]: (Result[T]) ⇒ T
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
final
def
task[T](f: ⇒ T): Task[T]
-
implicit final
def
textPipeTask[Key](in: Task[_])(implicit streams: Task[TaskStreams[Key]], key: (Task[_]) ⇒ Key): TextPipe
-
def
toString(): String
-
implicit final
def
toTask[T](f: () ⇒ T): Task[T]
-
implicit final
def
toTaskInfo[S](in: Task[S]): TaskInfo[S]
-
implicit final
def
toTasks[S](in: Seq[() ⇒ S]): Seq[Task[S]]
-
implicit final
def
upcastTask[A >: B, B](t: Task[B]): Task[A]
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
