Class ThreadSafeSubscriptions

Thread safe implementation of ISubscriptionsList for server-side code.

Inheritance
System.Object
ThreadSafeSubscriptions
Namespace: Eco.Core.Utils
Assembly: Eco.Core.dll
Syntax
public class ThreadSafeSubscriptions : Object, ISubscriptionsList, IEnumerable<ISubscription>, IEnumerable, ISubscription, ISupportNestedSubscriptions<ThreadSafeSubscriptions>, ISubscriptions<ThreadSafeSubscriptions>, ISubscriptions

Constructors

ThreadSafeSubscriptions()

Declaration
public ThreadSafeSubscriptions()

Properties

Subscriptions

Declaration
public ThreadSafeSubscriptions Subscriptions { get; }
Property Value
Type Description
ThreadSafeSubscriptions

Methods

AddNestedSubscriptions()

Declaration
public ThreadSafeSubscriptions AddNestedSubscriptions()
Returns
Type Description
ThreadSafeSubscriptions

AddSubscription(ISubscription)

Declaration
public void AddSubscription(ISubscription subscription)
Parameters
Type Name Description
ISubscription subscription

GetEnumerator()

Declaration
public ImmutableList<ISubscription>.Enumerator GetEnumerator()
Returns
Type Description
System.Collections.Immutable.ImmutableList.Enumerator<>

GetOrCreateSubscriptionsList()

Declaration
public ThreadSafeSubscriptions GetOrCreateSubscriptionsList()
Returns
Type Description
ThreadSafeSubscriptions

ReleaseSubscriptionsList()

Declaration
public void ReleaseSubscriptionsList()

RemoveSubscription(ISubscription)

Declaration
public bool RemoveSubscription(ISubscription subscription)
Parameters
Type Name Description
ISubscription subscription
Returns
Type Description
System.Boolean

Unsubscribe()

Declaration
public void Unsubscribe()

UnsubscribeAll()

Declaration
public void UnsubscribeAll()

UnsubscribeAll<TPredicate>(TPredicate)

Declaration
public void UnsubscribeAll<TPredicate>(TPredicate predicate)
    where TPredicate : IPredicate<ISubscription>
Parameters
Type Name Description
TPredicate predicate
Type Parameters
Name Description
TPredicate

UnsubscribeFirst<TPredicate>(TPredicate)

Declaration
public bool UnsubscribeFirst<TPredicate>(TPredicate predicate)
    where TPredicate : IPredicate<ISubscription>
Parameters
Type Name Description
TPredicate predicate
Returns
Type Description
System.Boolean
Type Parameters
Name Description
TPredicate

Implements

System.Collections.Generic.IEnumerable<>
System.Collections.IEnumerable

Extension Methods