[This is preliminary documentation and is subject to change.]
Overload List
Name | Description | |
---|---|---|
SubscribeR(StreamR, Epoch) |
Subscribes to a stream with no callback.
| |
SubscribeR(StreamR, Epoch, ActionIEnumerableR) |
Subscribes to a stream with a per-epoch callback applied by one worker.
| |
SubscribeR(StreamR, Epoch, ActionInt32, IEnumerableR) |
Subscribes to a stream with a per-epoch callback applied at each worker.
| |
SubscribeR(StreamR, Epoch, ActionInt32, Int32, IEnumerableR) |
Subscribes to a stream with a callback parameterized by worker id, epoch, and records.
| |
SubscribeR(StreamR, Epoch, ActionMessageR, Epoch, Int32, ActionEpoch, Int32, ActionInt32) |
Subscribes to a stream with callbacks for record receipt, epoch completion notification, and stream completion notification.
|
See Also