FRP örneği, olay döngüsü veya iş parçacığı havuzuyla

Question

Sorumluluk, ruby ​​rx kitaplığı için geçerlidir, ancak herhangi bir dilde herhangi bir örnek memnuniyetle karşılanacaktır. Temel olarak istediğim, her işlemi mevcut bir olay döngüsüne (veya bu konuya ait iş parçacığı havuzuna) zamanlamaktır. Sanırım bunun bir programcı tarafından yapılması gerekiyor. Yinelemeli işlemleri bir olay döngüsüne gönderen bir zamanlayıcı örneği bulamadım ve bu yüzden soruyorum. Neden olay döngü

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

: Burada yakut rx için liste? Çünkü olay döngüsünde çalışan ve eşzamanlılıktan yararlanan IO işlemlerini eklemek istiyorum. Böyle bir şey:

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

Bu normalde bir Zamanlayıcı ile yapılır ve ben RubyRx portu EventloopScheduler dahil olduğu beklenebilir.

Ya enqueue/bir ObserveOn operatör

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 

ile bunun üzerine onları scheduler veya

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 

Ben bu kod işe yarayabilir umut haritası eşzamanlılık ekleyebilir (C# değilim edebilirsiniz/JS)