イベントループまたはスレッドプールを使用したFRPの例

Question

私の質問はRuby rxライブラリの最終的なものですが、どの言語の例も喜んで感謝します。 基本的には、すべての操作を既存のイベントループ（またはスレッドプール）にスケジュールすることです。私はこれがスケジューラによって行われなければならないと思う。再帰的な操作をイベントループに送信するスケジューラーの例は見つかりませんでした。これが私が求めている理由です。ここでルビーRXのためのリストです：

https://github.com/ReactiveX/RxRuby/tree/master/lib/rx/concurrency

なぜイベントループ？イベントループ内で動作するIO操作を追加し、並行性を活用したいからです。このような何か：

Rx::Observable.from_enumerable(hosts). 
    map { |h| HTTP.connect(h) }. 
    map{|host| host.get("http://myservice/somelist.txt") }. 
    on_next { |html| parse(html).each_line.....} # you get the idea 

Answer 1

これは通常、スケジューラで行われ、私はRubyRxポートがEventloopSchedulerを含めていることを期待します。

あなたはエンキュー/ ObserveOnオペレータ

Rx::Observable.from_enumerable(hosts). 
    observeOn(els). # you have declared els somewhere else as an EventLoopScheduler instance 
    map { |h| HTTP.connect(h) }. 
    map{|host| host.get("http://myservice/somelist.txt") }. 
    on_next { |html| parse(html).each_line.....} # you get the idea 

とその上にそれらをスケジューラするか、またはあなたがマップに

Rx::Observable.from_enumerable(hosts). 
    observeOn(els). # you have declared els somewhere else as an EventLoopScheduler instance 
    map { |h| HTTP.connect(h) }. 
    flatmap{|host| Rx::Observable.start(host.get("http://myservice/somelist.txt"), els) }. 
    on_next { |html| parse(html).each_line.....} # you get the idea 

を並行処理を追加することができ、私はC＃の午前（コードは仕事ができることを願っています/ JS）