[This is preliminary documentation and is subject to change.]
Extension methods
Inheritance Hierarchy
Microsoft.Research.NaiadSubscribeExtensionMethods
Namespace: Microsoft.Research.Naiad
Assembly: Microsoft.Research.Naiad (in Microsoft.Research.Naiad.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public static class SubscribeExtensionMethods
Methods
| 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