| Copyright | © StrIoT maintainers 2021 |
|---|---|
| License | Apache 2.0 |
| Maintainer | StrIoT maintainers |
| Stability | experimental |
| Safe Haskell | Safe-Inferred |
| Language | Haskell2010 |
Striot.Simple
Description
The StrIoT fundamental data types and low-level operators for them. Import this module to write simple programs directly in terms of these operators and types.
This module re-exports Striot.FunctionalIoTtypes and
Striot.FunctionalProcessing, as well as three functions from
Striot.Nodes for convenience.
Synopsis
- module Striot.FunctionalIoTtypes
- module Striot.FunctionalProcessing
- mkStream :: [a] -> Stream a
- unStream :: Stream a -> [a]
- nodeSimple :: IO a -> (Stream a -> Stream b) -> (Stream b -> IO ()) -> IO ()
Documentation
module Striot.FunctionalIoTtypes
the fundamental Event and related types for encapsulating data within
StrIoT.
module Striot.FunctionalProcessing
The most basic stream processing functional primitives. These operate directly
upon the low-level Stream types.
unStream :: Stream a -> [a] Source #
A convenience function to extract a list of values from a Stream.
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.