Streamable.ToStreamEventObservable Yöntem

Tanım

Ad Alanı:

Microsoft.StreamProcessing

Bütünleştirilmiş Kod:

Microsoft.StreamProcessing.dll

Bütünleştirilmiş Kod:

Microsoft.StreamProcessing.dll

Aşırı Yüklemeler

ToStreamEventObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy)	Akış yapılabilir bir olayı gözlemlenebilir olarak dışarı aktarır. Sıralı eşitleme süresi olan olayları üretir.
ToStreamEventObservable<TPayload>(IStreamable<Empty,TPayload>, ReshapingPolicy)	Akış yapılabilir bir olayı gözlemlenebilir olarak dışarı aktarır. Sıralı eşitleme süresi olan olayları üretir.

ToStreamEventObservable<TKey,TPayload>(IStreamable<PartitionKey<TKey>,TPayload>, ReshapingPolicy)

Akış yapılabilir bir olayı gözlemlenebilir olarak dışarı aktarır. Sıralı eşitleme süresi olan olayları üretir.

public static IObservable<Microsoft.StreamProcessing.PartitionedStreamEvent<TKey,TPayload>> ToStreamEventObservable<TKey,TPayload>(this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload> stream, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null);

static member ToStreamEventObservable : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.PartitionKey<'Key>, 'Payload> * Microsoft.StreamProcessing.ReshapingPolicy -> IObservable<Microsoft.StreamProcessing.PartitionedStreamEvent<'Key, 'Payload>>

Tür Parametreleri

TKey

TPayload

Parametreler

stream

IStreamable<Microsoft.StreamProcessing.PartitionKey<TKey>,TPayload>

reshapingPolicy

ReshapingPolicy

Çıkışta olayların yeniden şekillendirilip şekillendirılmeyeceğini ve nasıl yeniden şekillendirildiğini belirten ilke. Varsayılan, olayları değiştirilmemiş olarak geçirir.

Döndürülenler

IObservable<PartitionedStreamEvent<TKey,TPayload>>

ToStreamEventObservable<TPayload>(IStreamable<Empty,TPayload>, ReshapingPolicy)

Akış yapılabilir bir olayı gözlemlenebilir olarak dışarı aktarır. Sıralı eşitleme süresi olan olayları üretir.

public static IObservable<Microsoft.StreamProcessing.StreamEvent<TPayload>> ToStreamEventObservable<TPayload>(this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> stream, Microsoft.StreamProcessing.ReshapingPolicy reshapingPolicy = null);

static member ToStreamEventObservable : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * Microsoft.StreamProcessing.ReshapingPolicy -> IObservable<Microsoft.StreamProcessing.StreamEvent<'Payload>>

Tür Parametreleri

TPayload

Parametreler

stream

IStreamable<Empty,TPayload>

reshapingPolicy

ReshapingPolicy

Çıkışta olayların yeniden şekillendirilip şekillendirılmeyeceğini ve nasıl yeniden şekillendirildiğini belirten ilke. Varsayılan, olayları değiştirilmemiş olarak geçirir.

Döndürülenler

IObservable<StreamEvent<TPayload>>