Streamable.ToStreamEventArrayObservable 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
| ToStreamEventArrayObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. |
| ToStreamEventArrayObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, Func<PartitionedStreamEvent<TKey,TPayload>[]>, ReshapingPolicy) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. |
| ToStreamEventArrayObservable<TPayload>(IStreamable<Empty,TPayload>, ReshapingPolicy) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. |
| ToStreamEventArrayObservable<TPayload>(IStreamable<Empty,TPayload>, Func<StreamEvent<TPayload>[]>, ReshapingPolicy) |
Exports a streamable as an observable of events. Produces events that are sync time ordered. |
ToStreamEventArrayObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy)
Exports a streamable as an observable of events. Produces events that are sync time ordered.
public static IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<TKey,TPayload>>> ToStreamEventArrayObservable<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload> stream, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null);static member ToStreamEventArrayObservable : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<'Key>, 'Payload> * Microsoft.StreamProcessing.ReshapingPolicy -> IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<'Key, 'Payload>>>Type Parameters
- TKey
- TPayload
Parameters
- stream
- IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>
- reshapingPolicy
- ReshapingPolicy
Policy that specifies whether and how events are reshaped at egress. Default passes events through unmodified.
Returns
Applies to
ToStreamEventArrayObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, Func<PartitionedStreamEvent<TKey,TPayload>[]>, ReshapingPolicy)
Exports a streamable as an observable of events. Produces events that are sync time ordered.
public static IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<TKey,TPayload>>> ToStreamEventArrayObservable<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload> stream, Func<Microsoft.StreamProcessing.PartitionedStreamEvent<TKey,TPayload>[]> generator, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null);static member ToStreamEventArrayObservable : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<'Key>, 'Payload> * Func<Microsoft.StreamProcessing.PartitionedStreamEvent<'Key, 'Payload>[]> * Microsoft.StreamProcessing.ReshapingPolicy -> IObservable<ArraySegment<Microsoft.StreamProcessing.PartitionedStreamEvent<'Key, 'Payload>>>Type Parameters
- TKey
- TPayload
Parameters
- stream
- IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>
- generator
- Func<PartitionedStreamEvent<TKey,TPayload>[]>
A function that returns an array that will be populated with stream results.
- reshapingPolicy
- ReshapingPolicy
Policy that specifies whether and how events are reshaped at egress. Default passes events through unmodified.
Returns
Applies to
ToStreamEventArrayObservable<TPayload>(IStreamable<Empty,TPayload>, ReshapingPolicy)
Exports a streamable as an observable of events. Produces events that are sync time ordered.
public static IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<TPayload>>> ToStreamEventArrayObservable<TPayload> (this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null);static member ToStreamEventArrayObservable : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * Microsoft.StreamProcessing.ReshapingPolicy -> IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<'Payload>>>Type Parameters
- TPayload
Parameters
- stream
- IStreamable<Empty,TPayload>
- reshapingPolicy
- ReshapingPolicy
Policy that specifies whether and how events are reshaped at egress. Default passes events through unmodified.
Returns
Applies to
ToStreamEventArrayObservable<TPayload>(IStreamable<Empty,TPayload>, Func<StreamEvent<TPayload>[]>, ReshapingPolicy)
Exports a streamable as an observable of events. Produces events that are sync time ordered.
public static IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<TPayload>>> ToStreamEventArrayObservable<TPayload> (this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, Func<Microsoft.StreamProcessing.StreamEvent<TPayload>[]> generator, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null);static member ToStreamEventArrayObservable : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * Func<Microsoft.StreamProcessing.StreamEvent<'Payload>[]> * Microsoft.StreamProcessing.ReshapingPolicy -> IObservable<ArraySegment<Microsoft.StreamProcessing.StreamEvent<'Payload>>>Type Parameters
- TPayload
Parameters
- stream
- IStreamable<Empty,TPayload>
- generator
- Func<StreamEvent<TPayload>[]>
A function that returns an array that will be populated with stream results.
- reshapingPolicy
- ReshapingPolicy
Policy that specifies whether and how events are reshaped at egress. Default passes events through unmodified.