RxJS Eşzamansız İstek Güncelleştirmesi

Question

Şu anda RxJS sayesinde Reaktif olarak düşünmeyi öğreniyorum. Şimdi, bir RxJS kitap (RxJS ile Reaktif Programlama) okuyorum ve AsyncSubject hakkında okudum ve sadece alınan son değeri nasıl önbelleğe alıyorum. Bilmek istediğim, sunucuyu güncellemek ve bu gözlemlenebilir güncellemeye sahip olmak istesem ne olur? OnComplete çağrıldığı için yepyeni bir gözlemci oluşturmam gerekiyor mu? Takip etmem gereken başka bir desen var mı?

Genel gereksinim, sunucuya veriyi sunucudan ve sunucudan temiz bir şekilde geçirme ve gözlemlenebilir (model) taze kalmamı sağlamaktır. onCompleted çağrıldıktan sonra

sayesinde Lee şüpheli olarak

Answer 1

, bir AsyncSubject değerini değiştiremez. Basit bir "basit bir" ile çağrı yapmak için tipik yolu "çağrıları arasındaki değeri önbelleğe alın" senaryosu, sunucu çağrınızı temsil eden bir AsyncSubject ile gözlemlenebilir tetiği eşlemek için flatMapLatest kullanmaktır. Eğer bazı verileri her 30 saniyede yenilemek istiyorsa Örneğin, böyle bir şey yapabilir: Senin durumunda

const subscription = Rx.Observable 
    .interval(30000) 
    .flatMapLatest(() => serverCall()) 
    .subscribe(x => doStuffWithResult(x)); 

Answer 2

istediğiniz beri, WebSockets kullanmayı düşünün your observable (model) fresh at all times

şey

gibi

var source = Rx.Observable.create(function (observer) { 
    websocket.onmessage = function(msg) { 
     observer.onNext(msg); 
    } 

    websocket.onerror = function(error) { 
     observer.onError(error); 
    } 

    websocket.onclose = function (msg) { 
     observer.onComplete(msg); 
    } 
}); 

Aksi takdirde bir aralık kullanabilirsiniz

const subscription = Rx.Observable 
    .interval(1000) 
    .flatMapLatest(() => Rx.Observable.fromPromise(fetch(...).then(response => response.json()).retry(5)) 
    .subscribe(response => response); 

Hata varsa hemen pes etmemek için retry operatörünü kullanabilirsiniz.