| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Network.Flink.Test
Description
This module is used to store all the utility functions used for testing.
Synopsis
- testStatefulFunc :: s -> (a -> Function s ()) -> a -> IO (FunctionState s)
Documentation
Arguments
| :: s | Initial state for test run |
| -> (a -> Function s ()) | Function to run |
| -> a | Input message |
| -> IO (FunctionState s) |
Function for testing stateful functions locally.
Runs function given some initial state and input message. The final state of the function is returned along with all messages, egress, etc. that were queued up to be sent to Flink during execution.
Function contains unsafe code, don't use for anything but test cases.