IAsyncStream<T> 接口

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.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)	将下一项传递给使用者。 当使用者已充分处理项的处理以满足任何行为保证时，应完成此方法返回的任务。 当使用者是) 流的 (生成者终结点时，当流实现已接受该项目的责任并保证满足其传递保证时，任务将完成。 例如，基于持久队列的流将在项持久保存后完成任务。 一个最多在传递后尽最大努力的流将返回一个已完成的任务。 当生成者是) 流的 (使用者终结点时，Task 应在使用者代码接受该项责任后完成。 具体而言，如果流提供程序保证至少传递一次，则在使用者返回的任务完成之前，不应将该项目视为已传递。 (继承自 IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	将下一批项传递给使用者。 当使用者已充分处理批处理中的所有项以满足任何行为保证时，应完成从此方法返回的任务。 也就是说，返回的 Task 的语义与 的 OnNextAsync(T, StreamSequenceToken)语义相同，针对批处理中的所有项扩展。 (继承自 IAsyncBatchProducer<T>)
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	为使用者订阅此可观测批。 (继承自 IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncBatchObserver<T>)	为使用者订阅此可观测批。 (继承自 IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	为使用者订阅此可观测项。 (继承自 IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>)	为使用者订阅此可观测项。 (继承自 IAsyncObservable<T>)

扩展方法

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<Exception,Task>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，它允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 的实例。
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，它允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 的实例。
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，它允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 的实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	使用委托将使用者订阅到此可观测项。 此方法是 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>, 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>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，它允许订阅类内联处理程序方法，而无需 IAsyncObserver 的实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,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>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，它允许订阅类内联处理程序方法，而无需 IAsyncObserver 的实例。