Streamable.RegisterAtemporalArrayOutput 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.
Overloads
| RegisterAtemporalArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, String) |
Registers an IStreamable object as an output of a query, with output as a list of change events. |
| RegisterAtemporalArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, Func<TPayload[]>, String) |
Registers an IStreamable object as an output of a query, with output as a list of change events. |
RegisterAtemporalArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, String)
Registers an IStreamable object as an output of a query, with output as a list of change events.
public static IObservable<ArraySegment<TPayload>> RegisterAtemporalArrayOutput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, string identifier = null);static member RegisterAtemporalArrayOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * string -> IObservable<ArraySegment<'Payload>><Extension()>
Public Function RegisterAtemporalArrayOutput(Of TPayload) (container As QueryContainer, stream As IStreamable(Of Empty, TPayload), Optional identifier As String = null) As IObservable(Of ArraySegment(Of TPayload))Type Parameters
- TPayload
The type of object being streamed
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Empty,TPayload>
An IStreamable object that is intended to be an output to the query.
- identifier
- String
A string that can uniquely identify the point of egress in the query.
Returns
An IObservable object of events for output data from the query.
Applies to
RegisterAtemporalArrayOutput<TPayload>(QueryContainer, IStreamable<Empty,TPayload>, Func<TPayload[]>, String)
Registers an IStreamable object as an output of a query, with output as a list of change events.
public static IObservable<ArraySegment<TPayload>> RegisterAtemporalArrayOutput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, Func<TPayload[]> generator, string identifier = null);static member RegisterAtemporalArrayOutput : Microsoft.StreamProcessing.QueryContainer * Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * Func<'Payload[]> * string -> IObservable<ArraySegment<'Payload>><Extension()>
Public Function RegisterAtemporalArrayOutput(Of TPayload) (container As QueryContainer, stream As IStreamable(Of Empty, TPayload), generator As Func(Of TPayload()), Optional identifier As String = null) As IObservable(Of ArraySegment(Of TPayload))Type Parameters
- TPayload
The type of object being streamed
Parameters
- container
- QueryContainer
The query container to which an egress point is being added.
- stream
- IStreamable<Empty,TPayload>
An IStreamable object that is intended to be an output to the query.
- generator
- Func<TPayload[]>
A function that returns an array that will be populated with stream results.
- identifier
- String
A string that can uniquely identify the point of egress in the query.
Returns
An IObservable object of events for output data from the query.