ObserverManager<TObserver> Class

Reference

Definition

Namespace:: Orleans.Utilities

Assembly:: Orleans.Core.dll

Package:: Microsoft.Orleans.Core v7.2.5

Package:: Microsoft.Orleans.Core v8.0.0

Package:: Microsoft.Orleans.Core v8.1.0

Package:: Microsoft.Orleans.Core v8.2.0

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Maintains a collection of observers.

public class ObserverManager<TObserver> : Orleans.Utilities.ObserverManager<Orleans.Runtime.IAddressable,TObserver>

type ObserverManager<'Observer> = class
    inherit ObserverManager<IAddressable, 'Observer>

Public Class ObserverManager(Of TObserver)
Inherits ObserverManager(Of IAddressable, TObserver)

Type Parameters

TObserver

The observer type.

Inheritance: Object

ObserverManager<IAddressable,TObserver>
ObserverManager<TObserver>

Constructors

ObserverManager<TObserver>(TimeSpan, ILogger)

Initializes a new instance of the ObserverManager<TObserver> class.

Properties

Count	Gets the number of observers. (Inherited from ObserverManager<TIdentity,TObserver>)
ExpirationDuration	Gets or sets the expiration time span, after which observers are lazily removed. (Inherited from ObserverManager<TIdentity,TObserver>)
GetDateTime	Gets or sets the delegate used to get the date and time, for expiry. (Inherited from ObserverManager<TIdentity,TObserver>)
Observers	Gets a copy of the observers. (Inherited from ObserverManager<TIdentity,TObserver>)

Methods

Clear()	Removes all observers. (Inherited from ObserverManager<TIdentity,TObserver>)
ClearExpired()	Removed all expired observers. (Inherited from ObserverManager<TIdentity,TObserver>)
GetEnumerator()	Returns an enumerator that iterates through the collection. (Inherited from ObserverManager<TIdentity,TObserver>)
Notify(Action<TObserver>, Func<TObserver,Boolean>)	Notifies all observers which match the provided `predicate`. (Inherited from ObserverManager<TIdentity,TObserver>)
Notify(Func<TObserver,Task>, Func<TObserver,Boolean>)	Notifies all observers. (Inherited from ObserverManager<TIdentity,TObserver>)
Subscribe(TIdentity, TObserver)	Ensures that the provided `observer` is subscribed, renewing its subscription. (Inherited from ObserverManager<TIdentity,TObserver>)
Unsubscribe(TIdentity)	Ensures that the provided `id` is unsubscribed. (Inherited from ObserverManager<TIdentity,TObserver>)