reactive-programming

0熱度

1回答

組合2個可觀察物體，以便只有當第二個發射時才發出下一個值

我有一個Observable Obs1已使用從對象數組開始的方法from創建。 我們假設數組有10個對象，這意味着Obs1會發射10次然後終止。 對於由發出的每個對象Obs1我想執行一個返回Observable的函數。因此，相同數量的數組的元素由函數返回的觀測量，我們姑且稱之爲Obs2-1Obs2-2 ... Obs2-10。這些觀測值只發出1個值，然後完成。 我想以某種OBS1鏈接到一系列的觀測

rxjs observable reactive-programming reactive 2017-12-02

---

0熱度

1回答

如何使用其他方法中的observable數據？

我正在使用Angular4應用程序。 這裏是我使用來獲得數據 - export class BookingService { constructor(private http: HttpClient) {} getMemberBookings(memberID: number): Observable<any> { return this.http.get('ht

javascript angular typescript observable reactive-programming 2017-10-21

---

0熱度

1回答

如何跳過可觀測量的項目，而組合使用RxJS與流逝的定時器處理

我有一個（費時）計算，類似的東西： async calculation(input: MyInputType): Promise<MyOutputType> { // fetch some infos from an HTTP endpoint // calculate result by combining received infos with input ret

javascript node.js typescript rxjs reactive-programming 2017-10-21

---

0熱度

1回答

RX.net的DropQueue機制

我遇到了RX.net的背壓問題，我找不到解決方案。我有一個可觀察的實時日誌消息流。 var logObservable = /* Observable stream of log messages */ ，我想通過他們正在通過網絡發送之前，該串行從logObservable實時日誌消息的TCP接口暴露。所以，我做到以下幾點： foreach (var message in logObserva

c# c#-4.0 system.reactive reactive-programming reactive 2017-10-28

---

0熱度

2回答

RxJava和一些編碼與rxjava它讓你想在一個完全不同的方式，我仍然無法理解我應該怎麼做時，我想要一些操作的一些數據保存在集合中（後收藏

保存數據可以說地圖的一個關鍵的價值），以便在所有請求完成後稍後處理。例如 可以說我想發出一些對某個API的調用，並在地圖中保存所有失敗的調用響應，以便稍後進行一些「錯誤更正」。 直到現在它看起來像我需要從上到下寫整個流程來做這個請求 - >錯誤 - >糾正這是一個操作管道，我想分離到兩個不同的操作發生在不同的時間。 我意識到我可能錯過了rxjava的一個關鍵概念。 總之我怎麼之外緩存數據的集合在以

multithreading asynchronous rx-java reactive-programming 2017-12-18

---

0熱度

2回答

Reactive和Resilient有什麼區別？

我在尋找Reactive和Resilient之間的區別。 我經歷了幾篇文章，但這些讓我有些清楚，但與外交解釋混淆很多。 我的理解彈性的意思是，如果同一個服務的實例的數量增加時請求的數量增加。同樣，如果請求較少，則會減少。所以，即使有多少個實例在增加或減少，其穩定狀態的容易和快速也被稱爲彈性。 我對無效沒有明確的想法。

parallel-processing akka reactive-programming distributed-computing distributed-system 2017-12-27

---

0熱度

1回答

當stream2基於stream1時，如何避免.zip（stream1，stream2，BiFun）兩次訂閱stream1？

我在android中使用firebase和一些複雜的數據。我需要保存引用，並且遇到了zip操作的問題，或者我處理RX的方式。 我想創建一個新的A object關於某種B信息，並更新我的B object有信息關於創建A。當火力業務均出現了成功，我將返回Single<A> val singleA = firebaseCall(A("ABC", bKey)) val singleB = single

android firebase-database reactive-programming rx-java2 rx-kotlin 2017-12-27

---

1熱度

1回答

有限源上的反應流保持未來事件打開

我正在使用Spring Webflux，Spring Data和Project Reactor進行非阻塞I/O（Spring Boot 2.0.0.M7）。 我的目標是創建一個類似股票代碼的API，以允許客戶端根據某些條件從端點請求所有資源，並接收在初始請求之後創建的新資源。 Reactive MongoDB是後備存儲。基本的HandlerFunction實現如下所示。 Mono<ServerRe

spring-data reactive-programming project-reactor spring-webflux 2017-12-27

---

0熱度

4回答

原因在簡單情況下使用反應式編程

請，有人可以給我解釋一下什麼是使用反應性風格的優點： Observable<String> greeting = Observable.just("Hello"); Observable<String> yelling = greeting.map(s -> s.toUppercase()); ，而不是簡單的命令式風格： String greeting = "Hello"; String

rx-java reactive-programming rx-java2 imperative-programming 2017-11-11

---

1熱度

1回答

如何模擬發射2 infiite Observable流，並有其他Observable每10秒合併它們並緩衝？

我想能夠模擬合併兩個單獨的流，它們發出一些對象（即擴展相同的父對象），使用緩衝區操作符緩衝它們並在10秒後發出收集的數據。我希望這種機制是無限的，這種合併/緩衝區總是在來自2個分離的流的排放時被調用。 以下是我迄今所做的： val list1 = mutableListOf<SomeClass1>( SomeClass1("1", 1), SomeClass1("2", 2), Som

kotlin rx-java reactive-programming rx-java2 2017-11-18

---