reactive-programming

1熱度

1回答

如何在Spring webflux應用程序中使用Spring WebSessionIdResolver和Spring Security 5？

目前我遇到了新的Spring反應堆棧，並且希望在Spring Session 2.0中使用反應式功能。 在傳統的Servlet方法中，Spring Session提供了一個HttpSessionStrategy來檢測cookie或請求頭中的會話。對於RESTful API，使用HeaderHttpSessionStrategy很容易實現令牌身份驗證（默認情況下他的名字是X-AUTH-TOKEN）。

spring spring-security reactive-programming spring-session spring-webflux 2017-10-14

---

1熱度

1回答

爲什麼反應式編程應用程序（vert.x）比單線程鎖定free，無阻塞Java應用程序更快？

我最近使用vert.x測試了一個簡單的HTTP服務器（基於java）我很驚訝http服務器的吞吐量和api延遲，它非常快。 http服務器的同一段代碼在java應用程序上運行，具有單線程，無鎖和非阻塞。性能不及vert.x one的三分之一。 我不明白的是，vert.x優於非反應式Java應用程序的核心技術差異是什麼？ STATS： 測試使用Jmeter完成。 jmeter和應用程序都運行在相同的

java multithreading http reactive-programming vert.x 2017-10-15

---

2熱度

1回答

Rx swift在使用flatMap後保持原始流的原始順序地圖

我試圖在中間應用flatMap之後保持原始順序。闡述了我的意思了圖 這裏是： ---- 2-4-1 ------------------（原始流） ----------- 1--2 --------- 4--（網絡活動 - 由flatMap延遲表示） ------ --------- --------- 2 4-1（那受通緝的結果） 下面是詳細情況代碼： persistMessageEventBu

reactive-programming rx-swift 2017-10-16

---

2熱度

3回答

如何使用Observable或async/await包裝異步回調？

我正在使用與回調一起工作的網絡API。所以基本上，我有一大堆的方法調用，我需要這個第三方庫，像這樣使用： void SendNetworkRequest(string requestType, Action<Response> callback) 我找到的代碼變得有點古怪，因爲我所有的方法依賴於網絡來自第三方API的資源也需要自行實現回調。舉例來說，在我的主場景我可能想要得到的球員資料和我的代

c# asynchronous async-await system.reactive reactive-programming 2017-10-17

---

2熱度

1回答

使用反應流的無源拉式背壓

這是我對該主題的理解。 有出版商和訂閱者。 爲發佈者和訂閱的僞碼是一樣的東西， Publisher{ Subscriber s; subscribe(Subscriber s){ this.s = s; s.onSubscribe(new Subscription(){ onRequest(int n){ List<Mess

java rx-java reactive-programming rx-java2 java-9 2017-10-17

---

1熱度

1回答

RxJs：到2個獨立的觀測

觀察到觸發 我有一個觀察的名爲「workcentersFiltered」式的Observable<Workcenter[]> 當我選擇一個廠，我可以成功過濾了我用下面的代碼工作中心 - 沒問題： this.workcentersFiltered = this.newLineForm.get('plant').valueChanges .flatMap(selectedPlant =>

javascript angular rxjs reactive-programming rxjs5 2017-10-18

---

0熱度

2回答

結合多個可觀察結果

我試圖實現這樣的事情： - 進行兩個不同的API調用並將結果組合到一個列表中。每次調用的結果都是一個HashMap，我有一個函數可以將它轉換爲一個列表。我現在想要做的是將列表合併爲一個，但我遇到了困難。 這是我的改裝服務看起來像： @GET("data/price?fsym=ETH") fun getETHRates(@Query("tsyms") tsyms : String) : Singl

android kotlin rx-java observable reactive-programming 2017-10-18

---

1熱度

1回答

RxJava：知道什麼時候可觀察完成並返回布爾值可以對調用者進行查看

我是RxJava的新手。我的經驗主要來自那些教程： Here和here。 現在，我發現自己處於一種與Retrofit2進行API調用的情況，該調用將返回Obesrvable<AccessToken>。客戶端將如下調用這個服務： public Observable<TokenResult> authenticateWithClientCredentials() { return auth

android rx-java reactive-programming rx-android rx-java2 2017-10-20

---

3熱度

3回答

導入可出租的RxJS運營商

RxJS 5.5做出了重大改變，並引入了lettable operators來替換我們以前用過的所有運營商（稱爲「運營商」）。 該文章包含一張紙條： Lettable operators can now be imported from rxjs/operators, but doing so without changing your build process will often resul

javascript angular typescript rxjs reactive-programming 2017-10-20

---

1熱度

2回答

使用RxJava更新並保留現有數據

我正在研究將我的（Android）應用程序中的某些邏輯轉換爲使用RxJava，但是我正在努力想出一種方法來執行一些更高級的邏輯。 用例如下：我想向用戶展示一種Feed。 Feed包含來自不同來源的項目，例如消息，文章等。由於API限制，應用程序本身必須收集各個資源並將其顯示在一個列表中。是 例如，假設我在飼料項目如下： class FeedItem { Type feedItem; //

rx-java reactive-programming rx-java2 2017-10-20

---