Share via


Streamable.ConsecutivePairs<TKey,TPayload,TResult> Method

Definition

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

Applies to