Reactive Extensionsを使って独立して購読/発行することはできますか？

Question

クラスMyClassがあるとします。

はこの二行目は、すべてのメソッドをトリガー

Observable.Publish(instanceOfMyClass); 

：私はこのような何かを持っている

Observable.Subscribe<MyClass>(myClass => DoSomething(myClass)); 

その後別の場所（ファイル/プロジェクト/時間）で：自分のコードの一部では、私はこのような何かをしたいですその正確なクラスタイプで購読されていました。 Reactive Extensions（v1またはv2）がサポートしているのですか？

サブスクリプション呼び出しの一部としてSynchronizationContextを指定すると便利です。メソッドがWeakReferenceで保持されるべきかどうかを指定するのも良いでしょう。そして、Publishメソッドは、すべてを同期して実行するか、私が待つことができる何かを与える能力を持っている必要があります。

Answer 1

これは作成するのが難しくありません。

内部にはDictionary<Type, Object>が必要で、Subject<T>（オブジェクトとして）をTypeで保存するだけです。

SubscribeとPublishの2つのメソッドを書き込んで、内部ディクショナリを処理できます。

実際には非常に簡単なはずです。

---

単なる単純なことではなく、私はそれをやり遂げると思った。

ここに私のRxパブ/サブクラスです：

public static class RxPS 
{ 
    private static Dictionary<Type, object> _subjects 
     = new Dictionary<Type, object>(); 

    public static IDisposable Subscribe<T>(Action<T> observer) 
    { 
     lock(_subjects) 
     { 
      if (!_subjects.ContainsKey(typeof(T))) 
      { 
       _subjects.Add(typeof(T), new Subject<T>()); 
      } 
      return (_subjects[typeof(T)] as Subject<T>) 
       .Subscribe(observer); 
     } 
    } 

    public static void Publish<T>(T item) 
    { 
     lock(_subjects) 
     { 
      if (_subjects.ContainsKey(typeof(T))) 
      { 
       (_subjects[typeof(T)] as Subject<T>) 
        .OnNext(item); 
      } 
     } 
    } 
} 

そして、これは、それが使用されている方法です。

RxPS.Publish(1); 
var d = RxPS.Subscribe<int>(x => Console.WriteLine(x)); 
RxPS.Publish(2); 
d.Dispose(); 
RxPS.Publish(3); 

結果は、このコードが唯一のコンソールに2を書くということです。

お楽しみください！

Answer 2

ReactiveUIのMessageBus classのようなものを探していると思います。このクラスは、基本的にType => IObservablesのDictionaryを持つだけで、Rxを使用してパブリッシュ/サブスクライブモデルを実装します。