machinecell-1.0.1: Arrow based stream transducers

Safe HaskellNone

Control.Arrow.Machine.Running

Contents

Synopsis

Run at once.

run :: ArrowApply a => ProcessA a (Event b) (Event c) -> a [b] [c]Source

Run step-by-step.

data ExecInfo fa Source

Represents return values and informations of step executions.

Constructors

ExecInfo 

Fields

yields :: fa
 
hasConsumed :: Bool
 
hasStopped :: Bool
 

Instances

Eq fa => Eq (ExecInfo fa) 
Show fa => Show (ExecInfo fa) 
Alternative f => Monoid (ExecInfo (f a)) 

stepRun :: ArrowApply a => ProcessA a (Event b) (Event c) -> a b (ExecInfo [c], ProcessA a (Event b) (Event c))Source

stepYield :: ArrowApply a => ProcessA a (Event b) (Event c) -> a b (ExecInfo (Maybe c), ProcessA a (Event b) (Event c))Source