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