QueryModule
PackageFCQRS
Summary
| Name | Signature | Synopsis |
|---|---|---|
| asDefaultSubscribe | asDefaultSubscribe inner | Adapt a generic ISubscribe<IMessageWithCID> to the non-generic ISubscribe (forwards every Subscribe overload to the inner subscription). |
| autoPublish | autoPublish handle offset evt | Adapt a "single-event" projection handler — one that just updates the read model and returns unit — to the canonical list-returning shape: after the handler runs, the journal event itself is published to subscribers whenever it is an IMessageWithCID. |
| filterPublish | filterPublish handle offset evt | Adapt a "filtered" projection handler — one that updates the read model and returns Publish/Suppress — to the canonical list-returning shape. |
| init | init actorApi offsetCount handler | No description available. |
Adapt a generic ISubscribe<IMessageWithCID> to the non-generic ISubscribe
(forwards every Subscribe overload to the inner subscription).
Parameters
| Name | Type | Description |
|---|---|---|
| inner | ISubscribe<IMessageWithCID> |
Returns
ISubscribe
Adapt a "single-event" projection handler — one that just updates the read
model and returns unit — to the canonical list-returning shape: after the
handler runs, the journal event itself is published to subscribers whenever
it is an IMessageWithCID. Aggregate Event<'T>s are; saga internals are
not, so subscribers only ever see aggregate events. This is the common
projection (notify with each event as-is); write a list-returning handler
when notifications must be filtered or transformed — e.g. suppressing
intermediate events so read-your-writes only wakes on the final one.
Parameters
| Name | Type | Description |
|---|---|---|
| handle | int64 -> obj -> unit | |
| offset | int64 | |
| evt | obj |
Returns
IMessageWithCID list
Adapt a "filtered" projection handler — one that updates the read model and
returns Publish/Suppress — to the canonical list-returning shape. Like
autoPublish, but the handler gets a per-event say over whether subscribers
wake: on Publish the journal event itself is notified (when it is an
IMessageWithCID), on Suppress nothing is. The middle ground between autoPublish
(always notify) and a hand-written list handler (notify anything).
Parameters
| Name | Type | Description |
|---|---|---|
| handle | int64 -> obj -> Notify | |
| offset | int64 | |
| evt | obj |
Returns
IMessageWithCID list