ObserverManager<TIdentity, TObserver>

1. Documentation
2. API reference
3. Microsoft.Orleans.Core
4. ObserverManager<TIdentity, TObserver>

class

Namespace: Orleans.Utilities

NuGetSourceMarkdown

Maintains a collection of observers.

public class ObserverManager<TIdentity, TObserver> : IEnumerable<TObserver>, IEnumerable
    where TIdentity : notnull

Constructors

• ObserverManager<TIdentity, TObserver>(TimeSpan, ILogger) Initializes a new instance of the Orleans.Utilities.ObserverManager class.

Properties

• Count Gets the number of observers.
• ExpirationDuration Gets or sets the expiration time span, after which observers are lazily removed.
• GetDateTime Gets or sets the delegate used to get the date and time, for expiry.
• Observers Gets a copy of the observers.

Methods

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