Streamable.ConsecutivePairs<TKey,TPayload,TResult> Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Finds patterns of events that are repeated consecutively
public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> ConsecutivePairs<TKey,TPayload,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> stream, System.Linq.Expressions.Expression<Func<TPayload,TPayload,TResult>> resultSelector);
static member ConsecutivePairs : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Func<'Payload, 'Payload, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>
<Extension()>
Public Function ConsecutivePairs(Of TKey, TPayload, TResult) (stream As IStreamable(Of TKey, TPayload), resultSelector As Expression(Of Func(Of TPayload, TPayload, TResult))) As IStreamable(Of TKey, TResult)
Type Parameters
- TKey
Key type
- TPayload
Payload type
- TResult
Result type
Parameters
- stream
- IStreamable<TKey,TPayload>
Input stream
- resultSelector
- Expression<Func<TPayload,TPayload,TResult>>
Compose result tuple using matching input events
Returns
IStreamable<TKey,TResult>
Pattern result stream