SubscribeExtensionsType
PackageFCQRS
Top-level C# extension methods for ISubscribe. These live at *namespace*
level (not nested inside the FCQRS.CSharp module) so C# actually discovers
them as extensions — consumers `using FCQRS;` and write
`subs.SubscribeFor(cid, n)` / `subs.SubscribeForFirst(cid)`.
Specification
Kind
Type
Members
5
Examples
0
SubscribeForSignature
SubscribeExtensions.SubscribeFor(subs, filter, take)
SubscribeForSignature
SubscribeExtensions.SubscribeFor(subs, cid, filter, take)
SubscribeForSignature
SubscribeExtensions.SubscribeFor(subs, cid, take)
SubscribeForFirstSignature
SubscribeExtensions.SubscribeForFirst(subs, cid, filter)
SubscribeForFirstSignature
SubscribeExtensions.SubscribeForFirst(subs, cid)
Summary
| Name | Signature | Synopsis |
|---|---|---|
| SubscribeFor | SubscribeExtensions.SubscribeFor(subs, filter, take) | Subscribe for `take` events matching a filter. |
| SubscribeFor | SubscribeExtensions.SubscribeFor(subs, cid, filter, take) | Subscribe for `take` events matching the correlation id and a filter. |
| SubscribeFor | SubscribeExtensions.SubscribeFor(subs, cid, take) | Subscribe for `take` events matching the correlation id. |
| SubscribeForFirst | SubscribeExtensions.SubscribeForFirst(subs, cid, filter) | Subscribe for the first event matching the correlation id and a filter. |
| SubscribeForFirst | SubscribeExtensions.SubscribeForFirst(subs, cid) | Subscribe for the first event matching the correlation id (take = 1). |
Subscribe for `take` events matching a filter.
Parameters
| Name | Type | Description |
|---|---|---|
| subs | ISubscribe<'T> | |
| filter | Func<'T, bool> | |
| take | int |
Returns
IAwaitableDisposable
Subscribe for `take` events matching the correlation id and a filter.
Parameters
| Name | Type | Description |
|---|---|---|
| subs | ISubscribe<'T> | |
| cid | CID | |
| filter | Func<'T, bool> | |
| take | int |
Returns
IAwaitableDisposable
Subscribe for `take` events matching the correlation id.
Parameters
| Name | Type | Description |
|---|---|---|
| subs | ISubscribe<'T> | |
| cid | CID | |
| take | int |
Returns
IAwaitableDisposable
Subscribe for the first event matching the correlation id and a filter.
Parameters
| Name | Type | Description |
|---|---|---|
| subs | ISubscribe<'T> | |
| cid | CID | |
| filter | Func<'T, bool> |
Returns
IAwaitableDisposable