Comment puis-je déterminer combien d'abonnés/effacer sur un IObservable <T>?

Question

Je me demande s'il existe un moyen de déterminer combien d'observateurs sont abonnés à un objet IObservable. J'ai une classe qui gère un HashTable d'instances IObservable filtrées, et je voudrais implémenter une routine de "bilan de santé" qui peut déterminer si les abonnés ont été retirés/éliminés, sans que chaque abonné ait à notifier explicitement cette classe qu'ils sont finis (c'est-à-dire devrait être implicite via Dispose() ou Unsubscribe()).

Cela ne répond pas vraiment à la question -

should-i-use-listiobserver-or-simply-actiont-to-keep-track-of-an-iobservable

Des idées experts Rx?

Answer 1

Il n'y a rien construit, mais vous pouvez mettre en œuvre un CountingSubject<T>:

public class CountingSubject<T> 
{ 
    private ISubject<T> internalSubject; 
    private int subscriberCount; 

    public CountingSubject() 
     : this(new Subject<T>()) 
    { 
    } 

    public CountingSubject(ISubject<T> internalSubject) 
    { 
     this.internalSubject = internalSubject; 
    } 

    public IDisposable Subscribe(IObserver<T> observer) 
    { 
     Interlocked.Increment(ref subscriberCount); 

     return new CompositeDisposable(
      this.internalSubject.Subscribe(observer), 
      Disposable.Create(() => Interlocked.Decrement(ref subscriberCount)) 
     }); 
    } 

    public int SubscriberCount 
    { 
     get { return subscriberCount; } 
    } 
} 

Answer 2

Puisque IObservable<T> ne fournit qu'une seule méthode, Subscribe, il n'y a aucun moyen d'obtenir le nombre d'abonnés. La liste d'abonnés est un détail d'implémentation qui n'est pas exposé via cette interface. Pour obtenir le nombre, quelle que soit la classe implémente, l'interface IObservable doit exposer une propriété ou une méthode pour obtenir le nombre, et le code client doit transtyper la référence IObservable à ce type, puis accéder à la propriété ou méthode.