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

android-如何在RxJava中链接任务

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

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

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

更新到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("

返回空结果的房间查询可能会使应用崩溃

我有一个房间查询： @Query("SELECT * FROM classes WHERE _id IN(:values) ORDER BY date DESC") fun getClassesByIds(values: List<Int>): Maybe<List<YClass>> compositeDisposable.add(viewModel.getClassesById(classesTaken)

从未使用过的观察者方法

我仍在尝试找出RxJava中的观察者.我有一个Retrofit客户端,一个实用程序方法和一个管理数据同步功能的类.当我尝试观察我的观测值时,我没有看到观察者已订阅的任何迹象. 我的效用方法 public static Single<Response<SyncResponse>> getSyncData() { Single response = FestAp

android-flatMap如何深入工作？

我对flatMap如何控制其“子”线程感兴趣,例如以下代码可以正常工作： private Flowable<PlcDataPackage> createIntervalPlcFlowable() { return Flowable.interval(1, TimeUnit.SECONDS, Schedulers.computation()) .onBackpressureLatest() .paralle

java-在Spring中创建新实例与使用范围原型注释之间的区别

我的应用程序正在侦听交换(使用rabbitMQ),希望接收一些API数据,然后将其重定向到相关位置. 当目的是打开一个新线程并通过每次创建RestClient来发送请求时,我正在使用rxJava来订阅这些更改.它会接收数据,解析,发送数据,然后将响应发送回队列. 我的问题是我想每次都创建我的RestClie

android-RxJava：知道何时可观察完成,并将布尔可观察的返回给调用方

我是RxJava的新手.我的经验主要来自这些教程： Here和here. 现在,我发现自己处于使用Retrofit2进行API调用的情况,该调用将返回Obesrvable< AccessToken>.客户端将按以下方式调用此服务： public Observable<TokenResult> authenticateWithClientCredentials() { return authS

android-RxJava2 toList()从不发出

所以我有下面的Disposable无效.我正在使用Room从表中获取所有行作为列表,将它们分别映射到某个东西并创建一个列表,然后它不会从那里继续. storedSuggestionDao .getSuggestionsOrderByType() //Flowable .doOnNext(storedSuggestions -> Timber.e("storedSuggestions: "

android-Retrofit 2-使用相同请求的内容管理http“ 204无内容”和“ 200”

我正在将Retrofit 2和OkHttp 3与RxJava2一起使用 我正在使用一些参数调用服务器.服务器根据这些参数返回带有对象列表的JSON.但是,如果没有要返回的内容,则服务器将返回’204-No Content’,而不是返回带有空列表的JSON.结果,我得到一个NullPointerException. 我知道如何管理JSON响

android-使用rxjava2遍历列表

我有一个自定义对象列表(List< Item> itemsList).这是我的自定义课程： public class Item { private String itemId; private String itemName; } 初始列表只有itemName； itemId将为空.我想遍历列表,为每个项目添加一个itemId,然后使用新列表,我需要对列表中的每个项目进行

Rxjava2阻止订阅与订阅

我已经阅读了有关blockingSubscribe()和subscribe()的解释,但是我既无法编写代码,也没有找到示例来查看它们之间的区别.看来这两种方式都是相同的.有人可以提供这两个示例,最好是用Java.解决方法:BlockingSubscribe阻止当前线程并在该线程上处理incomnig事件.您可以通过运行一些异

android-同一项目中的RxJava 1和RxJava 2

这个问题已经在这里有了答案：            >            How to resolve Duplicate files copied in APK META-INF/rxjava.properties                                    7个 我们的项目使用RxJava 1： compile 'io.re

android-CompositeDisposable.clear导致OkHttp抛出java.lang.IllegalStateException：不平衡的输入/退出

所以我有一个使用OkHttp的简单http请求.我使用Android上的RxJava进行此操作.我将此RxJava调用添加到CompositeDisposable中,然后在onStop上清除它.由于某种原因在下面触发了此异常.我对如何解决它不确定. Caused by java.lang.IllegalStateException: Unbalanced enter/exit

吞下错误后,上游永远不会完成

我正在使用RxJava遍历文件列表,进行网络调用以上传每个文件,然后将成功上传的文件收集到列表中,并将这些文件成功保存在订户中. 此代码有效,但发生错误时除外.行为应该是它记录错误并继续执行,除非发生错误,否则永远不会调用订阅者的onSuccess lambda. 观察者是否期望发出与原始可

android – 何时调用dispose并清除CompositeDisposable

我的问题可能是How to use CompositeDisposable of RxJava 2?的重复但要求澄清一个疑问. 根据接受的答案 // Using clear will clear all, but can accept new disposable disposables.clear(); // Using dispose will clear all and set isDisposed = true, so it will not acce

android – 使用retrofit和rxjava 2.x处理空响应

当使用rxjava 1.x时,我习惯返回Observable< Void>处理来自改造的空响应： @POST( "login" ) Observable<Void> getToken( @Header( "Authorization" ) String authorization, @Header( "username" ) String us

如何在RxJava2中链接两个Completable

我有两个可完成的.我想做以下场景： 如果第一个Completable到达onComplete,继续第二个Completable.最终结果将是第二次完成的完成. 当我有单个getUserIdAlreadySavedInDevice()和Completable login()时,我就是这样做的： @Override public Completable loginUserThatIsAlreadySavedInD

RxJava2 observable抛出UndeliverableException

据我所知,RxJava2 values.take(1)创建另一个Observable,它只包含原始Observable中的一个元素.哪个不能抛出异常,因为它被take(1)的效果过滤掉,因为它发生在第二个. 如下面的代码片段所示 Observable<Integer> values = Observable.create(o -> { o.onNext(1);

android – 未使用subscribe的结果

我今天已升级到Android Studio 3.1,这似乎增加了一些lint检查.其中一个lint检查是针对未存储在变量中的一次性RxJava2 subscribe()调用.例如,从我的Room数据库中获取所有玩家的列表： Single.just(db) .subscribeOn(Schedulers.io()) .subscribe(db -> db.p

android – 使用retrofit和rx java的多个api请求

我是android的新手,我有一个场景,我想从多个api获取数据.假设api_a,api_b,api_c,api_d.这些api彼此独立,但我想在混合Recycler View(水平和垂直)中显示来自这些api的数据.所以我想以这样的方式进行这些api调用,以便我可以一次获取每个api数据,以便我可以在回收器视图中显示. 我已经

android – 具有Backpressure的RxJava主题 – 只允许最后一个值在下游完成消耗后发出

我有一个PublishSubject在一些UI事件上调用onNext().订户通常需要2秒钟才能完成其工作.我需要忽略除了最后一个用户繁忙时对onNext()的所有调用.我尝试了以下,但是我无法控制流量.请求似乎排队等待,每个请求都得到处理(因此背压似乎不起作用).如何让它忽略所有请求,但最后一个？ (我

RxJava2：不要在`repeatWhen`中重复

我有一个Observable我想定期重复,但只是在一个条件下： apiInterface.getData() // returns Observable<Data> ... // processing is happening here .toList() .repeatWhen(completed -> { if (autoReload){ // Repeat every 3 seconds return completed.delay

RxJava过滤空列表并使用firstOrDefault

我正在尝试过滤一个列表,该列表可能是空的(或者该项不在列表中). inboxData由另一个observable填充： private BehaviorSubject<InboxResponse> inboxData = BehaviorSubject.create(); public Observable<Item> getInboxItem(String id) { return inboxData .flatMap(

Android Room中的交易与RxJava2

我的应用程序的一个要求是允许用户进行多个步骤,然后在完成时根据每个步骤中的条目将值写入数据库. UI中的每个步骤都可能有助于需要写入数据库的操作.数据可以在多个表中,并且属于这些表中的不同行.如果任何数据库操作失败,则整个操作应该失败. 我最初考虑将所有数据加载到内存中,