SubscribeExtensions (FCQRS)

SubscribeExtensions Type

Namespace: FCQRS
Assembly: FCQRS.dll
Base Type: obj

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)`.

Static members

Static member	Description
`SubscribeExtensions.SubscribeFor(subs, filter, take)` Full Usage: `SubscribeExtensions.SubscribeFor(subs, filter, take)` Parameters: subs : `ISubscribe<'T>` filter : `Func<'T, bool>` take : `int` Returns: `IAwaitableDisposable`	Subscribe for `take` events matching a filter. subs : `ISubscribe<'T>` filter : `Func<'T, bool>` take : `int` Returns: `IAwaitableDisposable`
`SubscribeExtensions.SubscribeFor(subs, cid, filter, take)` Full Usage: `SubscribeExtensions.SubscribeFor(subs, cid, filter, take)` Parameters: subs : `ISubscribe<'T>` cid : `CID` filter : `Func<'T, bool>` take : `int` Returns: `IAwaitableDisposable`	Subscribe for `take` events matching the correlation id and a filter. subs : `ISubscribe<'T>` cid : `CID` filter : `Func<'T, bool>` take : `int` Returns: `IAwaitableDisposable`
`SubscribeExtensions.SubscribeFor(subs, cid, take)` Full Usage: `SubscribeExtensions.SubscribeFor(subs, cid, take)` Parameters: subs : `ISubscribe<'T>` cid : `CID` take : `int` Returns: `IAwaitableDisposable`	Subscribe for `take` events matching the correlation id. subs : `ISubscribe<'T>` cid : `CID` take : `int` Returns: `IAwaitableDisposable`
`SubscribeExtensions.SubscribeForFirst(subs, cid, filter)` Full Usage: `SubscribeExtensions.SubscribeForFirst(subs, cid, filter)` Parameters: subs : `ISubscribe<'T>` cid : `CID` filter : `Func<'T, bool>` Returns: `IAwaitableDisposable`	Subscribe for the first event matching the correlation id and a filter. subs : `ISubscribe<'T>` cid : `CID` filter : `Func<'T, bool>` Returns: `IAwaitableDisposable`
`SubscribeExtensions.SubscribeForFirst(subs, cid)` Full Usage: `SubscribeExtensions.SubscribeForFirst(subs, cid)` Parameters: subs : `ISubscribe<'T>` cid : `CID` Returns: `IAwaitableDisposable`	Subscribe for the first event matching the correlation id (take = 1). subs : `ISubscribe<'T>` cid : `CID` Returns: `IAwaitableDisposable`