Udostępnij przez


Streamable.ToStreamEventArrayObservable Metoda

Definicja

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.

Zwraca

Dotyczy