rx-java2相关内容
我创建了一个Observable(RxJava2 + Volley),每5秒重复一次, 它可以工作,但是当我转储 Java堆(内存)时,我的 Model JAVA类的实例很多,并且每当Observable重复执行一次,它就会增加. br> 为什么RX创建我的模型的几个实例?我怎么只能使用它的一个实例? 模型 public RequestFuture getLiveRe
..
使用以下模式从Firebase实时数据库同步获取数据时: String s = Single.create(new SingleOnSubscribe() { @Override public void subscribe(SingleEmitter e) throws Exception { FirebaseDatabase.getI
..
在订阅Reactive Extensions Flowable 流时,我注意到在128个项目出现之后,该流暂停/挂起(不再发射任何将来的项目,并且没有返回错误)。 val下载:Flowable = sensor.downloadRecords() 下载 .doOnComplete {Log.i(“ TEST”,“ Finished!”)} .su
..
我是Dagger和Retrofit的新手。我有一个问题,尽管在dagger模块中声明了单例,仍在生成多个改装自定义拦截器实例。我只需要一个实例。 Dagger模块 @Module 公共类ApiModule { private Config config; public ApiModule(Config config){ this.config = config;
..
我正在使用RXJava2在广播接收器中发送电子邮件,我想知道何时应该退订该事件。该代码基本上是: getSmsMmsObservable() .subscribeOn(Schedulers.io()) 。 watchOn(AndroidSchedulers.mainThread()) .doOnError(throwable-> Timber.e(throwable,“发送邮件时出错。
..
我已经在 rxandroid问题页面上发布了此帖子,但没有响应已经4天了,但是没有响应,问题是调试apk中的rxjava功能按预期工作,但是在发行版apk中,仅与rxjava或rxandroid相关的功能根本不起作用 build.gradle(项目) apply plugin: 'com.android.application' //or apply plugin: 'java' ap
..
自从我集成了RxJava2以来,我在返回 Observable 的所有改造调用中都收到401未经身份验证的错误,因此我使用的是基本身份验证,我知道错误是由于此导致的,但是为什么呢?适用于调试但不能发布. 我认为Retrofit2的rxjava适配器的配置有问题 堆栈跟踪: com.jakewharton.retrofit2.adapter.rxjava2.HttpExceptio
..
嗨,我正在尝试向聊天添加一个新项目,我使用RXJava2调用了我的REST API,以通过嵌套的json响应获取聊天数据. 但是当我尝试向Arraylist中添加新项时(发送新消息),我得到了一个NullPointer: 09-08 13:35:14.529 2869-2869/com.jonathan.myapp E/AndroidRuntime: FATAL EXCEPTION
..
我目前正在使用rx-java 2,并且有一个用例,其中单个Camel Route用户需要使用多个Observable. 以此解决方案作为参考,我有一个部分可行的解决方案. RxJava-合并的Observable可以随时接受更多Observables吗? 我计划使用PublishProcessor,它将订阅到一个骆驼反应流订阅者,然后维护一个ConcurrentHashSet
..
搜索在我的应用程序中处于中心位置,我需要它能够正常运行.现在我有一个SearchView.我需要内联显示结果,所以我正在使用此代码. searchView.setOnQueryTextListener(new SearchView.OnQueryTextListener() { @Override public boolean onQueryTextS
..
我想知道是否有人可以阐明这个问题,何时使用 Single.fromCallable( ()-> myObject ) 代替 Single.just(myObject) 从文档Single.fromCallable(): /** * Returns a {@link Single} that invokes passed function and emits its r
..
我是android的新手,我有一种情况,我想从多个api获取数据.假设 api_a , api_b , api_c , api_d .这些api彼此独立,但我想在Recycler View混合视图(水平和垂直)中显示这些api的数据.因此,我想以这种方式进行这些api调用,以便一次可以获取每个api数据,以便可以在回收站视图中显示. 我已经在使用 retrofit 2 ,但是为此我不得不将它们一个
..
嘿,我正在使用Dagger2,Retrofit和OkHttp,并且我面临着依赖周期问题. 提供OkHttp时: @Provides @ApplicationScope OkHttpClient provideOkHttpClient(TokenAuthenticator auth,Dispatcher dispatcher){ return new OkHttpClient.B
..
DAO.class: @Dao public interface VisitorDAO { @Query("Select * from visitor") Flowable> getAll(); @Insert Completable Insert(Visitor visitor); //Using Single or M
..
我正在尝试将Room与RxJava和Retrofit一起使用,然后建议您使用组件弓(在这种情况下,该项目已成50%的机会,并且仅需要继续进行弓清理)是不可能的. 所以问题是这个.我有一个返回 POJO 的Web服务.像这样: { "success":"true", "message":"message", "data":{[ "id":"id", "name":"na
..
假设存在一个具有以下两种方法的Dao类: 1) delete(items: List): Completable 2) insert(items: List): Single> 如何将它们链接到Dao类中的以@transaction方法中,然后返回"insert method"的结果? 我想要一个具有这样签名的方法
..
我正在使用Room和RxJava,并且我想利用第二个功能来过滤来自第一个的数据. 比方说,房间正在回馈用户. Flowable getUsers() 然后,例如,我想按18岁以上的年龄过滤用户,因此我执行了以下操作: userDao.getUsers() .flatMap(listUser -> Flowable.fromIterable(listUse
..
我正在使用的版本是 implementation 'io.reactivex.rxjava2:rxjava:2.2.4' implementation 'io.reactivex.rxjava2:rxandroid:2.1.0' implementation 'com.jakewharton.rxbinding2:rxbinding:2.0.0' implementation 'com.ja
..
在房间中,@Delete注释不发出任何东西.这就是dao的样子 @Dao public interface UserDao { @Delete void deleteUser(User user); //We can't use Maybe or Single or anything here } 这在做类似的事情时会引起问题 userRepositor
..
我在“房间ORM"中有一个项目列表,希望在“回收者"视图中显示.数据正在从网络添加到数据库.问题是我每次都从Flowable而不是每个项目发出整个列表.我尝试使用.distinctUntilChanged进行了相同的操作. @Query("SELECT * FROM items") Flowable> getItems(); 我还尝试过仅返回单个项目,该项目仅加载第
..