Streamable.ToStreamEventArrayObservable Metoda
Definicja
Ważne
Niektóre informacje odnoszą się do produktu w wersji wstępnej, który może zostać znacząco zmodyfikowany przed wydaniem. Firma Microsoft nie udziela żadnych gwarancji, jawnych lub domniemanych, w odniesieniu do informacji podanych w tym miejscu.
Przeciążenia
| ToStreamEventArrayObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy) |
Eksportuje strumień jako możliwe do obserwowania zdarzeń. Tworzy zdarzenia uporządkowane w czasie synchronizacji. |
| ToStreamEventArrayObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, Func<PartitionedStreamEvent<TKey,TPayload>[]>, ReshapingPolicy) |
Eksportuje strumień jako możliwe do obserwowania zdarzeń. Tworzy zdarzenia uporządkowane w czasie synchronizacji. |
| ToStreamEventArrayObservable<TPayload>(IStreamable<Empty,TPayload>, ReshapingPolicy) |
Eksportuje strumień jako możliwe do obserwowania zdarzeń. Tworzy zdarzenia uporządkowane w czasie synchronizacji. |
| ToStreamEventArrayObservable<TPayload>(IStreamable<Empty,TPayload>, Func<StreamEvent<TPayload>[]>, ReshapingPolicy) |
Eksportuje strumień jako możliwe do obserwowania zdarzeń. Tworzy zdarzenia uporządkowane w czasie synchronizacji. |
ToStreamEventArrayObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy)
Eksportuje strumień jako możliwe do obserwowania zdarzeń. Tworzy zdarzenia uporządkowane w czasie synchronizacji.
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>>>
Parametry typu
- TKey
- TPayload
Parametry
- stream
- IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>
- reshapingPolicy
- ReshapingPolicy
Zasady określające, czy zdarzenia są przekształcane w ruch wychodzący i jak są zmieniane. Ustawienie domyślne przekazuje zdarzenia przez niezmodyfikowane.
Zwraca
Dotyczy
ToStreamEventArrayObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, Func<PartitionedStreamEvent<TKey,TPayload>[]>, ReshapingPolicy)
Eksportuje strumień jako możliwe do obserwowania zdarzeń. Tworzy zdarzenia uporządkowane w czasie synchronizacji.
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>>>
Parametry typu
- TKey
- TPayload
Parametry
- stream
- IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>
- generator
- Func<PartitionedStreamEvent<TKey,TPayload>[]>
Funkcja zwracająca tablicę, która zostanie wypełniona wynikami strumienia.
- reshapingPolicy
- ReshapingPolicy
Zasady określające, czy zdarzenia są przekształcane w ruch wychodzący i jak są zmieniane. Ustawienie domyślne przekazuje zdarzenia przez niezmodyfikowane.
Zwraca
Dotyczy
ToStreamEventArrayObservable<TPayload>(IStreamable<Empty,TPayload>, ReshapingPolicy)
Eksportuje strumień jako możliwe do obserwowania zdarzeń. Tworzy zdarzenia uporządkowane w czasie synchronizacji.
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>>>
Parametry typu
- TPayload
Parametry
- stream
- IStreamable<Empty,TPayload>
- reshapingPolicy
- ReshapingPolicy
Zasady określające, czy zdarzenia są przekształcane w ruch wychodzący i jak są zmieniane. Ustawienie domyślne przekazuje zdarzenia przez niezmodyfikowane.
Zwraca
Dotyczy
ToStreamEventArrayObservable<TPayload>(IStreamable<Empty,TPayload>, Func<StreamEvent<TPayload>[]>, ReshapingPolicy)
Eksportuje strumień jako możliwe do obserwowania zdarzeń. Tworzy zdarzenia uporządkowane w czasie synchronizacji.
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>>>
Parametry typu
- TPayload
Parametry
- stream
- IStreamable<Empty,TPayload>
- generator
- Func<StreamEvent<TPayload>[]>
Funkcja zwracająca tablicę, która zostanie wypełniona wynikami strumienia.
- reshapingPolicy
- ReshapingPolicy
Zasady określające, czy zdarzenia są przekształcane w ruch wychodzący i jak są zmieniane. Ustawienie domyślne przekazuje zdarzenia przez niezmodyfikowane.