Bolt (FsShelter)

Bolt Module

Namespace: FsShelter
Assembly: FsShelter.dll
Parent Module: DSL

Functions and values

Function or value	Description
`ofExternal comp` Full Usage: `ofExternal comp` Parameters: comp : `Component<'t>` Returns: `Bolt<'t>` Type parameters: 't	define a bolt for a (external) shell or java component comp : `Component<'t>` Returns: `Bolt<'t>`
`run mkArgs consume` Full Usage: `run mkArgs consume` Parameters: mkArgs : `(LogLevel -> string -> unit) -> Conf -> 't -> ('t -> unit) -> 'a` consume : `Consume<'a>` Returns: `Bolt<'t>` Type parameters: 't, 'a	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. mkArgs : `(LogLevel -> string -> unit) -> Conf -> 't -> ('t -> unit) -> 'a` consume : `Consume<'a>` Returns: `Bolt<'t>`
`runAsync mkArgs consume` Full Usage: `runAsync mkArgs consume` Parameters: mkArgs : `(LogLevel -> string -> unit) -> Conf -> 't -> ('t -> unit) -> 'a` consume : `AsyncConsume<'a>` Returns: `Bolt<'t>` Type parameters: 't, 'a	define an async bolt that auto-acks mkArgs: curried construction of arguments (log and conf applied only once) that will be passed into each consume() call. consume: async bolt function that will receive incoming tuples. mkArgs : `(LogLevel -> string -> unit) -> Conf -> 't -> ('t -> unit) -> 'a` consume : `AsyncConsume<'a>` Returns: `Bolt<'t>`
`runTerminator mkArgs consume` Full Usage: `runTerminator mkArgs consume` Parameters: mkArgs : `(LogLevel -> string -> unit) -> Conf -> 't -> 'a` consume : `Consume<'a>` Returns: `Bolt<'t>` Type parameters: 't, 'a	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. mkArgs : `(LogLevel -> string -> unit) -> Conf -> 't -> 'a` consume : `Consume<'a>` Returns: `Bolt<'t>`
`runTerminatorAsync mkArgs consume` Full Usage: `runTerminatorAsync mkArgs consume` Parameters: mkArgs : `(LogLevel -> string -> unit) -> Conf -> 't -> 'a` consume : `AsyncConsume<'a>` Returns: `Bolt<'t>` Type parameters: 't, 'a	define an async bolt that always nacks mkArgs: curried construction of arguments (log and conf applied only once) that will be passed into each consume() call. consume: async bolt function that will receive incoming tuples. mkArgs : `(LogLevel -> string -> unit) -> Conf -> 't -> 'a` consume : `AsyncConsume<'a>` Returns: `Bolt<'t>`