ObserverManager<TIdentity,TObserver> 类

定义

命名空间:

Orleans.Utilities

程序集:

Orleans.Core.dll

包:

Microsoft.Orleans.Core v8.2.0

维护观察程序集合。

public class ObserverManager<TIdentity,TObserver> : System.Collections.Generic.IEnumerable<TObserver>

type ObserverManager<'Identity, 'Observer> = class
    interface seq<'Observer>
    interface IEnumerable

Public Class ObserverManager(Of TIdentity, TObserver)
Implements IEnumerable(Of TObserver)

类型参数

TIdentity

地址类型，用于标识观察程序。

TObserver

观察程序类型。

继承

Object

ObserverManager<TIdentity,TObserver>

派生

Orleans.Utilities.ObserverManager<TObserver>

实现

IEnumerable<TObserver> IEnumerable

构造函数

ObserverManager<TIdentity,TObserver>(TimeSpan, ILogger)

初始化 ObserverManager<TIdentity,TObserver> 类的新实例。

属性

Count	获取观察程序的数目。
ExpirationDuration	获取或设置过期时间跨度，之后将延迟删除观察程序。
GetDateTime	获取或设置用于获取到期日期和时间的委托。
Observers	获取观察程序的副本。

方法

Clear()	删除所有观察程序。
ClearExpired()	删除了所有过期的观察程序。
GetEnumerator()	返回一个循环访问集合的枚举器。
Notify(Action<TObserver>, Func<TObserver,Boolean>)	通知与所提供的 predicate匹配的所有观察程序。
Notify(Func<TObserver,Task>, Func<TObserver,Boolean>)	通知所有观察者。
Subscribe(TIdentity, TObserver)	确保已订阅提供的 observer ，并续订其订阅。
Unsubscribe(TIdentity)	确保取消订阅提供的 id 。

显式接口实现

IEnumerable.GetEnumerator()

返回循环访问集合的枚举数。

扩展方法

BatchIEnumerable<T>(IEnumerable<T>, Int32)

维护观察程序集合。