rx-java

首页 > TAG信息列表 > rx-java

android-如何在RxJava中链接任务

我正在进行android应用程序注册,在该应用程序中,我需要一个接一个地执行几个任务任务1 任务2任务3 我想将这些任务一个接一个地链接起来,如果一个任务失败,则整个过程应该失败. 我想通过Rxjava解决此问题,谁能告诉我如何使用rxJava实现此问题. (我已经浪费了5个小时,但是在RxJava

选取元素直到某个字符并将其与RxJava分组

我对问题有一个简单的设置,但解决方案似乎更复杂. 设置：我有一个热的观察者,它起源于扫描仪,扫描仪将在编码完成时发出每个数字作为不同的元素,并发出R. 问题：从这开始,我想要一个热的可观察对象,它将每个完整代码作为1个元素发出. 我尝试过使用不同的flatMap,takeUntil和groupByope

如何使用Java RX Observable链接异步操作？

我想反复发出一个HTTP请求并根据结果采取行动.我从public Observable< NewsItem>开始fetchItems(NewsFeed提要).一个请求得到一些新闻,但我决定将其展平. 这个想法是使用Observable.interval()多次发出请求,然后将结果Observable合并为一个. Observable .inter

RxJava Backpressure(快速生产者缓慢的消费者)

我有执行方法,它会在io线程上进行一些耗时的网络调用例 /** * network call * @param value * @return */ private Observable<Integer> execute(final int value) { return Observable.create(new Observable.OnSubscribe<Integer>() { @Override publi

RxJava异步订阅

我有一个任务列表,应该在新线程中一个接一个地处理这些任务,然后结果应该由某个主线程显示在方法中.但是,这似乎不起作用,在主线程中调用了flatMap方法. 在这种情况下,为什么subscriptionOn方法不处理“线程切换”？在另一个线程中执行某些工作的更好模式是什么？ (除了使用Observable

android-如何顺序执行两个可观察对象？

如何依次执行两个可观察对象并在rxjava链中覆盖另一个结果？例如我有data1 = observableFromDb和data2 = observableFromServer; 我想将它们组合在一起,并用data2结果覆盖data1.解决方法:这就是concat运算符的作用-它在给定Observable的情况下顺序执行-另一个Observable直到上一个Ob

带有vararg observables的RxJava zip

当我们确切知道我们的确切类型有多少个可观察对象并且我们想压缩时,我们就这样做 Observable<String> data1 = Observable.just("one", "two", "three", "four", "five"); Observable<String> data2 = Observable.just("one", "two&

在rxjava中使用Observable序列进行一对多映射

给定一系列源对象的Observable,如何使用rxjava从每个输入对象映射多个输出对象？ (一对多映射) 我有一些菜式清单,它们代表组成餐厅订单的物品.我需要将每个菜转变为一个或多个OrderLine. 每张菜品地图都会为其名称价格创建一个OrderLine,为每个浇头创建一个OrderLine,如果有注释则创

如何使用RX Java在EventBus上正确处理onError

我在Android上使用rx java,我的事件总线类如下 public class EventBus { private final Subject<Event, Event> subject = new SerializedSubject<>(PublishSubject.<Event>create()); private Observable<Map<Type, Event>> stickyObservable; public Even

android-RxJava缓存网络调用

好的,所以我正在做一个项目,我需要从服务器获取Json,获取相应的POJO,填充一些视图并结束. 我面临的问题是,我必须嵌套网络调用才能获得所需的最终数据.为了最小化网络调用,我必须重用它们,这导致了真正复杂的RxOperator链.例如： getCarId() // network call .flatMap(carIdObj -

RxJava：使用“第一个”运算符时引发IllegalArgumentException

当我使用Observable.first()运算符时,出现了IllegalArgumentException消息,消息为“序列包含太多元素”. 这是一个可以重现异常的简化测试代码： Subject<Integer, Integer> subject = BehaviorSubject.create(); subject.first() .subscribe(integer -> subject.onNext(1))

android-RxJava：如何从flatMap运算符中的错误中恢复

我有一个EditText,用户在其中输入搜索查询,当用户键入内容时,我想在服务器上执行即时搜索. 我尝试使用RxJava做到这一点,如下所示： RxTextView.textChanges(editQuery) // I'm using RxBinding for listening to text changes .flatMap(new Func1<CharSequence, Observable<Use

RxJava-AbstractOnSubscribe在1.1.0中去了哪里？

版本1.1.0刚问世,似乎他们放弃了rx.observables.AbstractOnSubscribe Removals from Public API Observable.onBackpressureBlock rx.observables.AbstractOnSubscribe Removal of stateful methods from the generic rx.subjects.Subject abstract class AbstractOnSubscribe

RxJava / Android监视在不同时间触发的多个订阅者的进度

我正在寻找一种方法,希望使用RxJava来保持一致性,以监视可能在不同时间触发的多个订户的进度.我知道如何从一个方法中将所有用户同时触发后将它们合并或合并在一起,但是我不知道在不同时间从不同方法中触发它们时会采用哪种方法. 例如,如果我有2个长时间运行的任务附加到按钮按下上

android-使用RxJava将本地数据与远程(或缓存)数据连接

这是有效的代码,但是我有几个问题以及关于改进它的建议.我是RxJava的新手,我还没有完全了解如何将这些类型的可观察对象链接在一起. 我有两个模型对象,ListItem和UserInfo. ListItems存在于本地数据库中,并且使用从ListItem提供的ID从服务器获取UserInfo. UserInfo Web服务接受ID数

响应式流规范1.0发布后,jdbc规范也将变为响应式吗？

我正在学习并使用akka流进行反应式流编程,试图使用async-jdbc-driver或react-jdbc-driver的任何库已有2年了,我发现slick 3.0或rxjava-jdbc-driver提供了异步jdbc api,但我知道slick在JDBC api之上构建了令人惊叹的api,这正在阻塞(如果我错了,请纠正我),因此我认为从系统角度来看,

java-Spring MVC与反应流集成

我在Spring MVC上构建了一个RESTful API应用程序. 最近,我在spring mvc和反应式流之间进行了一些集成(例如rxjava和project-reactor),并尝试使应用程序更具反应性. 我刚刚在下面建立了一些演示： 1.对于rxjava,我使用PublishSubject private SerializedSubject<StreamResult, Stream

结合多个可观察对象的RxJava弹性方式

我有多个返回Observable的模块：O1,O2,O3 … 所有模块的结果应合并为一个可观察到的Ocomb,以使单个任务可能失败,但是合并不会因单个问题而终止或影响.使用当前的解决方案,我遇到了以下示例中的各种问题：这段代码结合了我的模块的输出： public Observable<Data> getModuleData(){

java-可以重用运算符执行

给出以下示例(kotlin代码) val subject = PublishSubject.create<Int>() val stream = subject.map { println("mapping") it * 2 } stream.forEach { println("A: $it") } stream.forEach { println("B: $it") } subject.onNext(1)

java-在Observable中返回从Observables收集的结果的最佳实践是什么？

我在我的项目中使用RxJava,但是这段代码让我有些困惑： @Override public Observable<Hexagon<T>> getHexagons() { return Observable.create(new OnSubscribe<Hexagon<T>>() { @Override public void call(final Subscriber<

单元测试时RxJava Schedulers.immediate()行为

我正在尝试为使用反应性接口的DAO对象编写测试.我有一个包含食谱的表,我想测试一下,当我向该表中插入数据时,订阅者会收到包含食谱的列表. 我正在使用TestSubscriber类,并对该类执行断言.我的简单测试如下所示： @Test fun testSubscriber() { insertItem() val testSubscri

RxJava Observable.fromEmitter奇数个反压行为

我一直在使用Observable.fromEmitter()作为Observable.create()的绝佳替代品.我最近遇到了一些奇怪的行为,我无法完全弄清楚为什么会这样.我真的很感谢一个对背压有一定了解的人,以及调度程序来看看这一点. public final class EmitterTest { public static void main(String[]

android-RxJava / RxBinding-检查订阅是否存在

我正在使用RxBinding并在onBindViewHolder方法的RecyclerView适配器中创建订阅,该订阅可重用项目.有没有简单的方法来检查是否已将订户分配给EditText对象,如果已删除,则删除该订户？我的代码看起来像这样 public void onBindViewHolder(final ItemViewHolder holder, int position

更新到RxJava2时出现“没有类型变量R的实例,因此Observable符合Observable”错误

我正在尝试使用翻新和rxJava调用API.使用RxJava 1时,以下代码似乎运行良好,但是一旦我更新到RxJava 2,就会收到此错误：错误： No Instance of type variable R exist so that Observable conforms to Observable 阿皮 Observable<HttpResult<List<Article>>> getList(@Query("

android-flatMap中的NetworkOnMainThreadException

我是rxjava或rxandroid的新手,我想将AsyncTask和回调地狱更改为Observable和Subscriber.但我对此有疑问.我需要对数据库执行两个请求. 我对第一个请求的答复将是第二个请求的结果.我尝试使用flatMap解决此问题.第一个请求返回值,一切正常,但是下一个请求给了我NetworkOnMainThreadE