implicit final class EvalProcess[F[_], O] extends AnyVal
Provides infix syntax for eval: Process[F,F[O]] => Process[F,O]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- EvalProcess
- AnyVal
- Any
- Hide All
- Show All
Visibility
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
##(): Int
- Definition Classes
- Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
eval: Process[F, O]
Evaluate the stream of
Factions produced by thisProcess.Evaluate the stream of
Factions produced by thisProcess. This sequencesFactions strictly--the firstFaction will be evaluated before work begins on producing the nextFaction. To allow for concurrent evaluation, usesequenceorgather. -
def
gather(bufSize: Int)(implicit F: Nondeterminism[F]): Process[F, O]
Read chunks of
bufSizefrom input, then useNondeterminism.gatherUnorderedto run all these actions to completion. -
def
getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val self: Process[F, F[O]]
-
def
sequence(bufSize: Int)(implicit F: Nondeterminism[F]): Process[F, O]
Read chunks of
bufSizefrom input, then useNondeterminism.gatherto run all these actions to completion and return elements in order. -
def
toString(): String
- Definition Classes
- Any