StreamSubscriptionHandle<T> Kelas

Definisi

Ruang nama:: Orleans.Streams

Rakitan:: Orleans.dll

Rakitan:: Orleans.Core.Abstractions.dll

Rakitan:: Orleans.Streaming.dll

Paket:: Microsoft.Orleans.Core v1.5.10

Paket:: Microsoft.Orleans.Core.Abstractions v2.4.5

Paket:: Microsoft.Orleans.Core.Abstractions v3.6.5

Paket:: Microsoft.Orleans.Streaming v7.2.5

Paket:: Microsoft.Orleans.Streaming v8.0.0

Paket:: Microsoft.Orleans.Streaming v8.1.0

Paket:: Microsoft.Orleans.Streaming v8.2.0

Paket:: Microsoft.Orleans.Streaming v9.0.0

Paket:: Microsoft.Orleans.Streaming v9.1.2

Sumber:: StreamSubscriptionHandle.cs

Penting

Beberapa informasi terkait produk prarilis yang dapat diubah secara signifikan sebelum dirilis. Microsoft tidak memberikan jaminan, tersirat maupun tersurat, sehubungan dengan informasi yang diberikan di sini.

Menangani mewakili langganan ini. Konsumen dapat membuat serialisasi dan menyimpan handel untuk berhenti berlangganan nanti, misalnya dalam aktivasi lain pada butir ini.

[System.Serializable]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>

[System.Serializable]
[Orleans.GenerateSerializer]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>

[<System.Serializable>]
type StreamSubscriptionHandle<'T> = class
    interface IEquatable<StreamSubscriptionHandle<'T>>

[<System.Serializable>]
[<Orleans.GenerateSerializer>]
type StreamSubscriptionHandle<'T> = class
    interface IEquatable<StreamSubscriptionHandle<'T>>

Public MustInherit Class StreamSubscriptionHandle(Of T)
Implements IEquatable(Of StreamSubscriptionHandle(Of T))

Jenis parameter

T

Warisan: Object
StreamSubscriptionHandle<T>

Atribut: SerializableAttribute GenerateSerializerAttribute

Penerapan: IEquatable<StreamSubscriptionHandle<T>>

Konstruktor

StreamSubscriptionHandle<T>()

Menangani mewakili langganan ini. Konsumen dapat membuat serialisasi dan menyimpan handel untuk berhenti berlangganan nanti, misalnya dalam aktivasi lain pada butir ini.

Properti

HandleId	Mendapatkan pengidentifikasi unik untuk StreamSubscriptionHandle ini
ProviderName	Mendapatkan nama penyedia.
StreamId	Mendapatkan pengidentifikasi aliran.
StreamIdentity	Menangani mewakili langganan ini. Konsumen dapat membuat serialisasi dan menyimpan handel untuk berhenti berlangganan nanti, misalnya dalam aktivasi lain pada butir ini.

Metode

Equals(StreamSubscriptionHandle<T>)	Menangani mewakili langganan ini. Konsumen dapat membuat serialisasi dan menyimpan handel untuk berhenti berlangganan nanti, misalnya dalam aktivasi lain pada butir ini.
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Lanjutkan konsumsi batch dari langganan ke aliran.
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	Melanjutkan konsumsi dari langganan ke aliran.
UnsubscribeAsync()	Berhenti berlangganan konsumen stream dari pengamatan ini.

Metode Ekstensi

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Melanjutkan konsumsi aliran menggunakan delegasi. Metode ini adalah pembantu untuk StreamSubscriptionHandle.ResumeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Melanjutkan konsumsi aliran menggunakan delegasi. Metode ini adalah pembantu untuk StreamSubscriptionHandle.ResumeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Melanjutkan konsumsi aliran menggunakan delegasi. Metode ini adalah pembantu untuk StreamSubscriptionHandle.ResumeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Disingkirkan jika fungsi filter aliran yang disediakan tidak cocok. Biasanya ini karena ini bukan metode statis.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Melanjutkan konsumsi aliran menggunakan delegasi. Metode ini adalah pembantu untuk StreamSubscriptionHandle.ResumeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Melanjutkan konsumsi aliran menggunakan delegasi. Metode ini adalah pembantu untuk StreamSubscriptionHandle.ResumeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Melanjutkan konsumsi aliran menggunakan delegasi. Metode ini adalah pembantu untuk StreamSubscriptionHandle.ResumeAsync yang memungkinkan kelas berlangganan untuk menginline metode handler alih-alih memerlukan instans IAsyncBatchObserver.

Berlaku untuk

Bagikan melalui