reactive-programming

0熱度

1回答

我有一個Spring Boot 1.4.3項目。最近我想出了一個要求，即必須將日誌從服務器發送到我的Web應用程序，並在網頁上打印日誌。我意識到WebSockets，但我正在尋找更好的解決方案，並且遇到了Reactive Programming和gRPC。 Spring在Spring 5版本中支持Reactive Programming，但是我對gRPC和Reactive Programming之

0熱度

1回答

適應RxJava 1.1.5反應堆核心3.1.0.M3

我想使用RxJava 1.1.5與Spring WebFlux（即反應堆核心3.1.0.M3），但我無法適應ObservableFlux。我想這將是相對簡單的，但我的適配器不工作： import reactor.core.publisher.Flux; import rx.Observable; import rx.Subscriber; import rx.Subscription;

2熱度

2回答

if/else in Reactive JDK 8

我是Reactive的新手。使用JDK 1.8，如何將這些命令式代碼轉換爲無效式。 List<int> evenArr, oddArr, arr; // pretending 'arr' have some values, 'evenArr' & 'oddArr' have already init for (int n : arr) { if (n%2) evenArr.add(n

2熱度

2回答

Spring 5 WebClient使用ssl

我試圖找到WebClient使用的例子。我的目標是使用Spring 5 WebClient使用https和自簽名證書查詢REST服務任何示例？

3熱度

1回答

使用throttleTime函數關於主題angular2錯誤

我試圖在主題上使用throttleTime操作符。我輸入了操作員。我收到這個錯誤：this.cropSubject.asObservable(...).throttleTime is not a function。我無法弄清楚發生了什麼問題。這是一個錯誤？ import { Observable } from 'rxjs/Observable'; import { Subject } from

0熱度

1回答

使用Reactor實現http速率限制服務重試

我剛剛在Java中使用Reactor 3進行了反應式編程。我想使用reactor-netty實現一個http服務的客戶端。到目前爲止，我有非常基本的http請求被完美髮送。但是，該服務期望客戶遵守費率限制（通過傳統的X-RateLimit-Limit，X-RateLimit-Remaining等標題通知客戶）。我想要在速度限制時自動重試請求，但我不確定什麼是最具「慣用」或有效的方式來做到這一點與

0熱度

1回答

如何確定Observable.merge中可觀察的變化？

下面你可以看到我的代碼，我已經簡化了可讀性和清晰度： connect(): Observable<Customer[]> { const displayDataChanges = [ this._customerDatabase.dataChange, this._filterChange, this._sort.mdSortChange, thi

4熱度

3回答

在無擴展預定義的順序排序可觀察

說我有一個類型T： class T { public int identifier; //Arbitrary but unique for each character (Guids in real-life) public char character; //In real life not a char, but I chose char here for easy dem

1熱度

1回答

如何在RxJs中執行操作後重試觀察值？

我正在使用Angular 2和RxJS從我的API層檢索數據。我有一個基礎服務，我已經寫出來處理HTTP請求。下面的代碼做到這一點我的服務範圍內： protected apiGet(uri: string): Observable<HttpMappedResponse<T>> { return this.mapAndHandle<T>(this.http.get(uri)); }

0熱度

1回答

R Shiny，如何在observeEvent調用中更新變量

我無法更新observeEvent調用中的列表。該列表被稱爲Participants並且是列表列表 - 即每個用戶的配置文件。 Participants應該由任何用戶在某個observeEvent調用中更新。我已經嘗試了使變量被動，也沒有被動，但它不起作用。下面是一個最小工作示例 ui.R 的代碼爲用戶 library(shiny) shinyUI(fluidPage( side