Safe Haskell	None
Language	Haskell2010

Test.Dataflow

Synopsis

runDataflow :: MonadIO io => (Edge o -> Dataflow (Edge i)) -> [i] -> io [o]
runDataflowMany :: MonadIO io => (Edge o -> Dataflow (Edge i)) -> [[i]] -> io [[o]]

Documentation

runDataflow :: MonadIO io => (Edge o -> Dataflow (Edge i)) -> [i] -> io [o] Source #

Run a dataflow with a list of inputs. All inputs will be sent as part of a single epoch.

Since: 0.1.0.0

runDataflowMany :: MonadIO io => (Edge o -> Dataflow (Edge i)) -> [[i]] -> io [[o]] Source #

Run a dataflow with a list of lists of inputs. Each outer list will be sent as its own epoch.

Since: 0.2.2.0