[This is preliminary documentation and is subject to change.]
Registers a callback that will be invoked each time the collection changes with a list of weighted records.
Namespace: Microsoft.Research.Naiad.Frameworks.DifferentialDataflow
Assembly: Microsoft.Research.Naiad.DifferentialDataflow (in Microsoft.Research.Naiad.DifferentialDataflow.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public static Subscription Subscribe<TRecord>( this Collection<TRecord, Epoch> input, Action<Weighted<TRecord>[]> action ) where TRecord : Object, IEquatable<TRecord>
Parameters
- input
- Type: Microsoft.Research.Naiad.Frameworks.DifferentialDataflow.Collection<TRecord, Epoch>
The input collection. - action
- Type: System.Action<Weighted<TRecord>[]>
An action that is called with the list of weighted records from each epoch.
Type Parameters
- TRecord
- The type of the input records.
Return Value
Type: SubscriptionA Subscription object for synchronization.
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type Collection<TRecord, Epoch>. When you use instance method syntax to call this method, omit the first parameter. For more information, see Extension Methods (Visual Basic) or Extension Methods (C# Programming Guide).See Also