1

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üFRP örneği, olay döngüsü veya iş parçacığı havuzuyla

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 

cevap

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)

+0

Tam olarak eksik olduğum programlayıcının tanımı, gördüğüm örneklerin çoğunun üzerine yazmama izin verdiğim (#schedule_relative, #schedule_recu) rsive, #schedule_recursive_with_state ...) ve anlamak için kavga ettiğim etkileşimler. Mevcut örnekleri biliyor musunuz (belki C# veya JS'de)? – ChuckE

+1

C# için Schedulers burada bazı şeyler yazdım --http: //introtorx.com/Content/v1.0.10621.0/15_SchedulingAndThreading.html. EventLoopScheduler'ın RxRuby'den eksik olduğu anlaşılıyor. Bu bir PR oluşturmak ve ona katkıda bulunmak için bir fırsat olabilir. –

+0

sadece bir değil, aynı zamanda bir iş parçacığı havuzu zamanlayıcısı da eksik gibi görünüyor. ona bir göz atacağım ve neleri başarabileceğimi göreceğim. – ChuckE