reactivex

1热度

1回答

我对RxJs非常陌生，并且没有阅读过解决方案。更详细的解释是在评论，但基本上我想处理一个组合键（我认为缓冲区会这样做），当一个特定的键被按下（如按“O”将等待其他键按下很短的时间），但是立即处理键输入（除非“o”没有被按下，或者“o”的“超时”已经通过），否则不是“o”。 Observable.fromEvent(document, 'keydown') // Now I want t

0热度

1回答

RxSwift - 如何节制缓冲区的时间跨度

我正在尝试重新创建一个代码片段，该代码片段基本上统计一个按钮在一行中被单击的次数。代码是在RxJS中，我试图将它转换为RxSwift用于学习目的，但是可以找出缓冲区和节流部分。 You can see the js code on jsfiddle 目前我有这个 tapButton.rx.tap .buffer(timeSpan: 0.25, count: 10, scheduler:

1热度

2回答

在RxJava2中实现滑动窗口

我想在RxJava2中实现一个简单的滑动窗口功能，但努力做我想做的事情。我的目标是采取对象的流，即 ["a", "b", "c", "d", "e"] 并应用滑动窗口将返回相邻元素中的元素。即导致： ["a", "b"] ["a", "b", "c"] ["b", "c", "d"] ["c", "d", "e"] ["d", "e"]. I.E. a-------------

0热度

1回答

zip rxjava运营商不能解决方法订阅

我想通过网络发送多个请求，这tutorial 帮助，但我卡在后半部分。似乎我预计将从onSubscribe，onNext，...返回一个值（OrderValues）... 因为apply函数返回一个值。但是，onNext默认返回void。任何帮助吗？这是我的一段代码 Observable<Restaurant> orderRestaurant= IdentityClient.getAPISer

4热度

3回答

如何重复ajax请求，直到RxJS Observable满足条件？

我试图重复一个请求，直到响应中有使用RxJS的数据，此时我想调用成功（或失败）处理程序，但是我遇到了RxJS问题。这是我目前的做法： // ... redux-observable action observable .mergeMap(() => fetchData() .repeatWhen(response => response.takeWhile(({

1热度

1回答

这是一个可取消Observable的合理实现吗？

我有一个多步骤的过程 - 一个回调函数和两个promise-returns函数 - 我想在它周围构建一个支持被取消的Observable。我得到的是： let observableFromEvent = evt => Observable.create(({ next, error, complete }) => { let canceled Promisify(callbac

0热度

2回答

rxjava .zip onNext（）未执行

我组合了zip中的多个观察者以执行来自服务器的多个请求，但onNext未执行，因此我无法获取返回的值。 menuName，restaurantName和userName是全局变量。 public void getOrderValues(String restaurantIdx,String menuIdx,String userIdx) { try { Observable

0热度

1回答

ReactiveX Java过程早期完成？

public class ReactiveExample { public static void main(String[] args) throws InterruptedException, NumberFormatException, UnsupportedEncodingException { Observable.range(1, 5).subscribe(

0热度

1回答

用ReactiveX逐行图像加载

我试图加载缩小的预览图像，然后是雇用图像。我想确保如果有任何机会，雇用图像首先加载，预览图像被丢弃。考虑以下示例，其中：序列1是预览图像请求序列2是员工图像请求序列3是组合的序列序列4是所得图像渲染序列。 Example 1: 1 ------P------- 2 ---------H---- 3 ------P--H---- 4 ------*--*---- Ex

0热度

1回答

rxpy将物品注入可观察区域

此问题与有关。我想构建一个处理来自可观察源消息的反应系统。除此之外，我正试图将它与基于zookeeper的领导者选举系统相结合。这种组合只允许一个进程场中的一个领导者处理消息流。以下是我正在尝试构建的代码的要点。 # event_source is an observable of messages # manager.leaders is an observable of leader