コールバックをRx.Observableに変換するには？

Question

外部ライブラリがイベントの代わりにコールバックを登録するだけの場合は、Observableを作成する最も良い方法は何ですか？

イベントの場合はObservable.FromEventPatternを使用できますが、このケースでは私が持っている唯一のアイデアは、Subjectを使用し、各コールバックでイベントをキューに入れることです。

これを行うにはもっと良い方法はありますか？

Answer 1

イベントを発生させ、そのメソッドをコールバックとして渡すメソッドを作成します。

Answer 2

使用Observable.Create.はここに例を示します

void Main() 
{ 
    var target = new SampleCallbacker(); 
    var actionB = new Action<int>(i => Console.WriteLine($"{i} * {i} = {i * i}.")); 
    target.Register(actionB); 

    var observable = Observable.Create<int>(observer => 
    { 
     var action = new Action<int>(i => observer.OnNext(i)); 
     target.Register(action); 
     return() => target.Unregister(action); 
    }); 

    var subscription = observable.Subscribe(i => Console.WriteLine($"From observable: {i} was fired.")); 

    target.Fire(1); 
    target.Fire(2); 
    target.Fire(3); 
    Console.WriteLine("Unsusbscribing observable..."); 
    subscription.Dispose(); 
    target.Fire(4); 
    target.Fire(5); 
} 

class SampleCallbacker 
{ 
    private List<Action<int>> _actions = new List<System.Action<int>>(); 
    public void Register(Action<int> action) 
    { 
     _actions.Add(action); 
    } 

    public void Unregister(Action<int> action) 
    { 
     while (_actions.Remove(action)) 
     {} //loop remove 
    } 

    public void Fire(int i) 
    { 
     foreach (var action in _actions) 
     { 
      action(i); 
     } 
    } 
} 

Answer 3

それは（例えば、クエリに対する応答を待っているために）単一のコールバックだ場合、あなたはStartAsyncメソッドを使用するにも使用することができます。現代のほとんどのAPIは、タスク/約束をサポートする可能性が高い。

Observable.StartAsync<string>(cancellation => 
    { 
     var source = new TaskCompletionSource<string>(); 
     yourlib.RegisterCallback(source.SetResult); 
     cancellation.Register(() => yourlib.UnregisterCallback(source.SetResult)); 
     return source.Task; 
    }); 

あなたが複数のサブスクリプションを避けたい場合は、いつでもこれ以上の加入者が存在しないときに処分されます単一subcriptionを共有するために.Publish().RefCount()を使用することができます。