Streamable.Publish<TKey,TPayload> Method

Definition

Performs dynamic version of multicast over a streamable. This allows query writers to execute multiple subqueries over the same physical input stream - streams can be added or removed. It is up to the user to ensure that the stream has no end edges, otherwise a dynamically subscribed subscriber may receive a malformed stream (end edge without corresponding start edge). Usage: stream.Publish(); stream.Subscribe(...); stream.Connect(); stream.Subscribe(...);

public static Microsoft.StreamProcessing.IConnectableStreamable<TKey,TPayload> Publish<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source);
static member Publish : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> -> Microsoft.StreamProcessing.IConnectableStreamable<'Key, 'Payload>
<Extension()>
Public Function Publish(Of TKey, TPayload) (source As IStreamable(Of TKey, TPayload)) As IConnectableStreamable(Of TKey, TPayload)

Type Parameters

TKey
TPayload

Parameters

Returns

Applies to