IAsyncStream<T> 介面

定義

命名空間:

Orleans.Streams

組件:

Orleans.Streaming.dll

套件:

Microsoft.Orleans.Streaming v8.1.0

這個介面代表物件，其做為產生者和取用者之間的分散式交集。 它類似于回應式架構 Subject ，並實作 IObserver 和 IObservable 介面。

public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IAsyncStream

type IAsyncStream<'T> = interface
    interface IAsyncStream
    interface IEquatable<IAsyncStream<'T>>
    interface IComparable<IAsyncStream<'T>>
    interface IAsyncObservable<'T>
    interface IAsyncBatchObservable<'T>
    interface IAsyncBatchProducer<'T>
    interface IAsyncObserver<'T>

Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IAsyncStream, IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T))

類型參數

T

流經資料流程的物件類型。

實作

IAsyncObservable<T> IAsyncObserver<T> IComparable<IAsyncStream<T>> IEquatable<IAsyncStream<T>> IAsyncBatchObservable<T> IAsyncBatchProducer<T> IAsyncStream

屬性

StreamId

取得資料流程識別碼。 (繼承來源 IAsyncStream)

方法

GetAllSubscriptionHandles()	擷取此資料流程呼叫端所建立之所有作用中訂用帳戶的清單。
OnCompletedAsync()	通知取用者資料流程已完成。 當取用者完成處理資料流程關閉時，應該完成從這個方法傳回的工作。 (繼承來源 IAsyncObserver<T>)
OnErrorAsync(Exception)	通知取用者資料流程發生錯誤。 當取用者完成處理資料流程關閉時，應該完成從這個方法傳回的工作。 (繼承來源 IAsyncObserver<T>)
OnNextAsync(T, StreamSequenceToken)	將下一個專案傳遞至取用者。 當取用者已充分處理專案處理，以符合任何行為保證時，應該完成從這個方法傳回的工作。 當取用者是) 資料流程的 (產生者端點時，當資料流程實作接受專案的責任，並確保其傳遞保證完成工作。 例如，根據長期佇列的資料流程會在專案永久儲存時完成工作。 最多一次傳遞時提供最佳工作的資料流程會傳回已經完成的工作。 當產生者是) 資料流程 (取用者端點時，當取用者程式碼接受專案的責任時，應該由取用者程式碼完成工作。 特別是，如果資料流程提供者保證至少傳遞一次，則在取用者傳回的工作完成之前，不應將專案視為傳遞。 (繼承來源 IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	將下一批專案傳遞至取用者。 當取用者已充分處理批次中的所有專案，以符合任何行為保證時，應該完成從這個方法傳回的工作。 也就是說，傳回之工作的語意與 OnNextAsync(T, StreamSequenceToken) 針對 批次中的所有專案擴充相同。 (繼承來源 IAsyncBatchProducer<T>)
SubscribeAsync(IAsyncBatchObserver<T>)	訂閱取用者以取得此可觀察的批次。 (繼承來源 IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	訂閱取用者以取得此可觀察的批次。 (繼承來源 IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncObserver<T>)	訂閱取用者以取得此可觀察的。 (繼承來源 IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	訂閱取用者以取得此可觀察的。 (繼承來源 IAsyncObservable<T>)

擴充方法

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncBatchObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncBatchObserver 的實例。
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncBatchObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncBatchObserver 的實例。
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncBatchObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncBatchObserver 的實例。
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncBatchObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncBatchObserver 的實例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	使用委派訂閱取用者以取得此可觀察的。 這個方法是 IAsyncObservable.SubscribeAsync 的協助程式，可讓訂閱類別內嵌處理常式方法，而不需要 IAsyncObserver 的實例。