Bolt
Namespace: FsShelter
Parent Module: DSL
Functions and values
| Function or value | Description |
ofExternal comp
Signature: comp:Component<'t> -> Bolt<'t>
Type parameters: 't |
define a bolt for a (external) shell or java component |
run mkArgs consume
Signature: mkArgs:((LogLevel -> string -> unit) -> Conf -> 't -> ('t -> unit) -> '?8213) -> consume:Consume<'?8213> -> Bolt<'t>
Type parameters: 't, '?8213 |
define a bolt that auto-acks mkArgs: curried construction of arguments (log and conf applied only once) that will be passed into each next() call. consume: bolt function that will receive incoming tuples. |
runTerminator mkArgs consume
Signature: mkArgs:((LogLevel -> string -> unit) -> Conf -> 't -> '?8216) -> consume:Consume<'?8216> -> Bolt<'t>
Type parameters: 't, '?8216 |
define a bolt that always nacks mkArgs: curried construction of arguments (log and conf applied only once) that will be passed into each next() call. consume: bolt function that will receive incoming tuples. |
