SubClient
Namespace: XRay
Attributes:
[<CompilationRepresentation(4)>]
[<RequireQualifiedAccess>]
Operations on publish-subscribe channels.
Functions and values
| Function or value | Description |
complete(ch op)
Signature: ch:SubClient<'m,'a> -> op:Span -> Span
Type parameters: 'm, 'a |
Completes an operation consuming a message from a publish-subscribe channel. |
consumer(ch opName f)
Signature: ch:SubClient<'m,'a> -> opName:string -> f:(Span -> 'a -> Async<'b>) -> 'm -> Async<'b>
Type parameters: 'm, 'a, 'b |
|
error(ch op error)
Signature: ch:SubClient<'m,'a> -> op:Span -> error:string -> Span
Type parameters: 'm, 'a |
|
start(ch opName m)
Signature: ch:SubClient<'m,'a> -> opName:string -> m:'m -> 'a * Span
Type parameters: 'm, 'a |
Starts an operation to consume a message from a publish-subscribe channel. |
