DispatchAsync (FsShelter) | FsShelter

DispatchAsync Module

Namespace: FsShelter
Assembly: FsShelter.dll

Async dispatch functions for spouts and bolts

Functions and values

Function or value	Description
`autoAckBolt mkArgs consume (getAnchors, act, deact) getStream conf out` Full Usage: `autoAckBolt mkArgs consume (getAnchors, act, deact) getStream conf out` Parameters: mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b -> ('c -> unit) -> 'd` consume : `'d -> 'e` getAnchors : `string * string -> TupleId -> TupleId list` act : `'b option` deact : `'b option` getStream : `'c -> string` conf : `'a` out : `OutCommand<'c> -> unit` Returns: `InCommand<'b> -> Task<unit>` Type parameters: 'a, 'b, 'c, 'd, 'e (requires :> System.Threading.Tasks.Task<Microsoft.FSharp.Core.unit>)	Dispatch bolt commands and auto ack/nack handled messages (async consume) mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b -> ('c -> unit) -> 'd` consume : `'d -> 'e` getAnchors : `string * string -> TupleId -> TupleId list` act : `'b option` deact : `'b option` getStream : `'c -> string` conf : `'a` out : `OutCommand<'c> -> unit` Returns: `InCommand<'b> -> Task<unit>`
`autoNackBolt mkArgs consume conf out` Full Usage: `autoNackBolt mkArgs consume conf out` Parameters: mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b -> 'c` consume : `'c -> 'd` conf : `'a` out : `OutCommand<'e> -> unit` Returns: `InCommand<'b> -> Task<unit>` Type parameters: 'a, 'b, 'c, 'd, 'e (requires :> System.Threading.Tasks.Task<Microsoft.FSharp.Core.unit>)	Dispatch bolt commands and auto-nack all incoming messages (async consume) mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b -> 'c` consume : `'c -> 'd` conf : `'a` out : `OutCommand<'e> -> unit` Returns: `InCommand<'b> -> Task<unit>`
`reliableSpout mkArgs mkAcker deactivate next getStream conf out` Full Usage: `reliableSpout mkArgs mkAcker deactivate next getStream conf out` Parameters: mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b` mkAcker : `'b -> (TupleId -> unit) * (TupleId -> unit)` deactivate : `'b -> unit` next : `'b -> 'c` getStream : `'d -> string` conf : `'a` out : `OutCommand<'d> -> unit` Returns: `InCommand<'t> -> Task<unit>` Type parameters: 'a, 'b, 'c, 'd, 't (requires :> System.Threading.Tasks.Task<(FsShelter.TupleId * 'd) Microsoft.FSharp.Core.option>)	Dispatch spout commands and handle acknowledgements (async next) mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b` mkAcker : `'b -> (TupleId -> unit) * (TupleId -> unit)` deactivate : `'b -> unit` next : `'b -> 'c` getStream : `'d -> string` conf : `'a` out : `OutCommand<'d> -> unit` Returns: `InCommand<'t> -> Task<unit>`
`unreliableSpout mkArgs deactivate next getStream conf out` Full Usage: `unreliableSpout mkArgs deactivate next getStream conf out` Parameters: mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b` deactivate : `'b -> unit` next : `'b -> 'c` getStream : `'d -> string` conf : `'a` out : `OutCommand<'d> -> unit` Returns: `InCommand<'t> -> Task<unit>` Type parameters: 'a, 'b, 'c, 'd, 't (requires :> System.Threading.Tasks.Task<'d Microsoft.FSharp.Core.option>)	Dispatch commands for spouts that don't provide unique ids (async next) mkArgs : `(LogLevel -> string -> unit) -> 'a -> 'b` deactivate : `'b -> unit` next : `'b -> 'c` getStream : `'d -> string` conf : `'a` out : `OutCommand<'d> -> unit` Returns: `InCommand<'t> -> Task<unit>`