Safe Haskell	Safe-Inferred
Language	Haskell2010

Striot.Nodes

Synopsis

nodeSimple :: IO a -> (Stream a -> Stream b) -> (Stream b -> IO ()) -> IO ()
mkStream :: [a] -> Stream a
unStream :: Stream a -> [a]

Documentation

nodeSimple :: IO a -> (Stream a -> Stream b) -> (Stream b -> IO ()) -> IO () Source #

a simple source-sink combined function for single-Node deployments. The first argument is a Source function to create data. The second is the pure stream-processing function. The third is a Sink function to operate on the processed Stream.

mkStream :: [a] -> Stream a Source #

Convenience function for creating a pure Stream.

unStream :: Stream a -> [a] Source #

A convenience function to extract a list of values from a Stream.