dataflower 0.1.3.0 → 0.1.4.0

raw patch · 2 files changed

+7/−6 lines, 2 filesPVP: major bump suggested

API removals or changes: PVP suggests a major version bump

API changes (from Hackage documentation)

Files

• dataflower.cabal +2/−2
• src/Dataflow.hs +5/−4

@@ -4,10 +4,10 @@ -- -- see: https://github.com/sol/hpack ----- hash: d5432eeb692ca789729a8cbc13ee3678552e761c8f8fc1bcdb0eb05befc63ab4+-- hash: b4d9c5533fc659e6801a98a43183cb91426ce81a603cc0267578d5a1cba664ad  name:           dataflower-version:        0.1.3.0+version:        0.1.4.0 synopsis:       A Pure-Haskell Timely Dataflow System description:    See README homepage:       https://github.com/doublecrowngaming/dataflower#readme

@@ -31,6 +31,7 @@ ) where  import           Control.Monad              (void)+import           Control.Monad.IO.Class     (MonadIO (..)) import           Control.Monad.State.Strict (execStateT, runStateT) import           Data.Traversable           (Traversable) import           Dataflow.Primitives@@ -48,15 +49,15 @@ -- | Take a 'Dataflow' which takes 'i's as input and compile it into a 'Program'. -- -- @since 0.1.0.0-compile :: Dataflow (Edge i) -> IO (Program i)-compile (Dataflow actions) = uncurry Program <$> runStateT actions initDataflowState+compile :: MonadIO io => Dataflow (Edge i) -> io (Program i)+compile (Dataflow actions) = liftIO $ uncurry Program <$> runStateT actions initDataflowState  -- | Feed a traversable collection of inputs to a 'Program'. All inputs provided will -- have the same 'Timestamp' associated with them. -- -- @since 0.1.0.0-execute :: Traversable t => t i -> Program i -> IO ()-execute corpus Program{..} = execDataflow feedInput+execute :: (MonadIO io, Traversable t) => t i -> Program i -> io ()+execute corpus Program{..} = liftIO $ execDataflow feedInput   where     feedInput           = input corpus programInput     execDataflow action = void $ execStateT (runDataflow action) programState