reactivex

0热度

1回答

我正在为我的应用制作启动画面。我希望它在进入主屏幕前至少持续N秒。我有一个Rx变量myObservable从服务器或从我的本地缓存中返回数据。我如何强制myObservable在中完成至少N秒？ myObservable // .doStuff to make it last at least N seconds .subscribe(...)

1热度

1回答

RxJava2将两个Flowables合并为一个

我很努力地找到任何将两个Flowable合并成一个的RxJava2实例。我想修改包括沿 Integer[] ints = new Integer[count]; Integer[] moreints = new Integer[count]; Arrays.fill(ints, 777); Arrays.fill(moreints, 777); Fl

2热度

1回答

RxJS可观察连续不工作

concat调用发生了什么？我知道如果我通过merge代替concat，代码正常工作，输出为foobarquxquux。我已经阅读了关于热和冷的可观察性，并且我知道如果在订阅之前生成的值可能会发生热的可观察性，但是我的可观察性下面有cold，所以我认为情况并非如此。 const Rx = require('rxjs'); const observable1 = Rx.Observable.cr

1热度

1回答

如何使用Rx操作符仅在前一个不同时发布布尔值？

我有一个布尔Observable。我只想在当前布尔值与预览不同的情况下发出值（另一个布尔值）。 booleanObservable // which operator here .subscribe(new Consumer<Boolean>() { @Override public void accept(Boolean emitt

0热度

1回答

如何从xstream Stream上的.map（）发送错误？

比方说，我想流发出在某些情况下的错误： import xs from 'xstream' //... function transformBlah(blah) { if (blah.status >= 200 && blah.status < 300) { return blah.body } else { return new Error('I w

1热度

1回答

将无限流的无限流转换为无限流 - 活性X

1热度

1回答

通过rxpy从可观察值返回值

将rx.Observable对象转换为函数中的“普通”对象的优雅方式是什么？如： def foo(): return rx.Observable.just('value').subscribe(<some magic here>) >>> print(foo()) # expected: # value # however get: # <rx.disposables.a

0热度

1回答

如何在Angular Heroes教程中合并2个搜索？

我想在Angular/TypeScript中合并2个HTTP获取搜索，但我无法正常工作。使用Angular 2/4 Tour of Heroes教程来说明情况，该教程使用Observable通过“name”值搜索英雄（https://angular.io/tutorial/toh-pt6#add-the-ability-to-search-by-name）。在英雄search.service.t

1热度

2回答

使用Reactivex的消费者接口

我是ReactiveX的新手。我从源代码中学习它。一切都很清楚，但突然之间我得到了一个名为“消费者”的词，这是一个界面。它被用来代替Observer。有人可以让我知道它到底做了什么吗？我跟随了几个链接，但他们只是说了一条语句Consumer是一个接受单个值的函数接口（回调函数）。我想知道它的确切工作。这是什么？我们为什么需要它？如何使用它？它代替观察者吗？如果是，如何和为什么？

0热度

1回答

可观察NOT NULL和值可观测真

这是一个有点困难的一个解释，先看看代码： public static IObservable<bool> NotNullAnd<T>(IReadOnlyReactiveProperty<T> prop, Func<T, IObservable<bool>> andSelector) { var notNull = prop.Select(l => l != null);