自定义RxJava Observable在订阅时不发出任何内容

文章/答案/技术大牛

发布

1回答

observable、rx-kotlin

reader.readLine() } return stringBuilder.toString() return Observable.create}

浏览 11提问于2018-12-24得票数 0

2回答

如果订阅过程中出现异常怎么办？

java、rx-java、reactivex、subscriber

我正在尝试将“第三方”publisher封装到RxJava中。在订阅期间，我正在准备publisher，这可能会导致异常(当publisher不可用时)。我应该如何处理异常？我正在考虑推送OnError，那么如何实现订阅呢？如果OnError应该是subscription中的最后一个事件，我应该将其视为subscription发生还是不发生？

浏览 2提问于2017-01-26得票数 0

1回答

使用countDownLatch.await()确保交付结果

android、rx-java2、countdownlatch

schedulerProvider: BaseSchedulerProvider lateinit var goals: Observable<List<SavingsGoal>> }.subsc

浏览 14提问于2020-11-28得票数 0

回答已采纳

1回答

rxjava2 -如何将使用者作为参数传递

rx-java2

我在android中使用以下rxjava依赖项：compile 'io.reactivex.rxjava2:rxandroidprotected abstract Observable buildUseCaseObservable(); //RETROFIT WILL BUILD THE OBSERVABLE FOR ME SOM

浏览 4提问于2017-06-08得票数 2

回答已采纳

1回答

如何在RxJava中刷新可观察到的？

android、functional-programming、reactive-programming、rx-java

return r.getItems(); .observeOn(AndroidSchedulers.mainThread())); mAddressAdapter.swapItems(items);当订阅初始化完成时我试过了然后打电话 mObservable.subscribe(items -

浏览 3提问于2014-12-01得票数 6

回答已采纳

1回答

Observable.OnSubscribe接口的方法调用及其完整描述

rx-java

我探索了在RxJava中创建新的观察者的不同方法。 ( interface Observable.OnSubscribe<T> )失败了。请任何人帮我找出这个方法是干什么的，或者分享一些关于这个方法的详细信息。非常感谢!

浏览 1提问于2018-06-28得票数 1

回答已采纳

1回答

无法实现BufferUntil RxJava

java、rx-java

尝试为BufferUntil实现Observable (即，每当满足某些条件时，缓冲区元素和发出缓冲列表)界定：尝试为RxJava实现完全相同的public <T extends Object> <e

浏览 5提问于2017-02-16得票数 2

回答已采纳

1回答

为什么我只能向最近的订户发送一条信息？

angularjs、coffeescript、rxjs

.@observable = Rx.Observable.create (source) =>@observable2= Rx.Observable.create (source) =>$timeout => ,1000/&#

浏览 5提问于2017-07-18得票数 0

回答已采纳

1回答

在ConnectableObservable内执行异步查询时出现线程问题

java、android、asynchronous、observable、rx-java

super String> stringStreamInput; @Override public void call(Subscriber<?

浏览 29提问于2019-01-22得票数 1

回答已采纳

1回答

RxJava异步订阅将丢失消息

rx-java2

我正在学习RxJava异步订阅是如何工作的。但有些问题让我困惑。@Test public void testCreateAsync() throws InterruptedException {@Test public void testCreateAsyn

浏览 1提问于2017-06-23得票数 1

回答已采纳

3回答

我使用Observable.create()来创建一个可观察的，以便在调度程序上执行一些工作(例如，Schedulers.io()，然后在AndroidSchedulers.mainThread()上返回一个结果val subscription = observable<T> { // perform action synchronously当用户决定取消它时，我取消订阅可观察到的：subscription.unsubsc

浏览 0提问于2015-05-12得票数 6

回答已采纳

3回答

如何使用RxJava来降低按钮的点击生成事件的速度？

android、rx-java、rx-java2

是否可以使用RxJava来确保这种行为？我试着从RxJava上读到了RxJava，但我发现这真的很难理解。

浏览 5提问于2017-06-28得票数 1

回答已采纳

3回答

RxJava:链接可观察对象

java、android、scala、promise、rx-java

是否可以使用RxJava实现类似next chaining的功能： .then( (someData) -> { return fetchUserDataObservable(someData); }).then(

浏览 3提问于2014-11-15得票数 43

回答已采纳

1回答

RxJava Observable.cache失效

android、rx-java

我试图在Android环境中学习rxjava。假设我有一个可以观察到的，它发出一个网络呼叫的结果。如果我正确理解的话，处理配置更改的一种普遍的方法是：非常感

浏览 5提问于2015-07-30得票数 16

回答已采纳

1回答

是否有一个与RxJava的onDispose相当的Kotlin协同通道？

kotlin、rx-java、kotlin-coroutines、kotlinx.coroutines.channels

如果我在RxJava中扩展了一个RxJava，我可以覆盖OnDispose()，并执行清理，比如为垃圾收集器清除一些东西。每当释放对此OnDispose()的任何订阅时，都会调用Observable<>。我知道channel.close()，但这是不一样的。有什么方法可以传播频道的订阅处理/取消？

浏览 1提问于2019-07-16得票数 1

1回答

Observable.zip选择不同的调度程序来订阅不同的调用。

java、rx-java、reactivex

我通过Observable.zip()函数压缩它们，但是每次订阅都在不同的调度程序上。我预计所有可观察到的o1、o2和z都应该在可观测的Schedulers.io()上订阅。<String> o1 = Observable.just("o1").subscribeOn(Schedulers.computation()); Observable<String> o2 = Observable.just("o2&q

浏览 4提问于2017-03-27得票数 1

1回答

在RxJava中取消订阅线程安全吗？

java、reactive-programming、rx-java

假设我有以下RxJava代码(它访问DB，但确切的用例与此无关)： return Observable.create(new Observable.OnSubscribe<List<DbPlaceDto>>() {subscriber.onError(e);

浏览 4提问于2015-09-22得票数 7

回答已采纳

2回答

除了System.currentTimeMillis()之外，使用.defer()还有什么好的用例

rx-java、reactive-programming、rx-java2

Random.nextInteger(); }我们的想法是，如果我们创建另一个createPlayerSingle()订阅return dao.createSingle(id);} 我确实理解defer的作用(它为每个订阅者执行lambda，例如，如果我们将System.currentTimeMillis()放在lambda中，我们将为2个订阅接收2个不同的值，而如果我们使用.just或.fromCallable而不是.d

浏览 0提问于2018-04-11得票数 2

2回答

RxJava观测器不兼容类型

java、android、rx-java、retrofit2、rx-android

我试图使用Retrofit和RxJava在我正在处理的应用程序中的自定义视图中进行API调用，但当我尝试订阅Retrofit调用中的可观察到的API时，我遇到了一个不兼容的类型错误。Posts> getPosts ( @Query("address") String address} 以及位于自定义视图的onFinishInflate()中的Retro

浏览 2提问于2017-04-15得票数 4

1回答

RxJava -将一个冷的可观测的转变为热的可观测的

rx-java、rx-java2

我想解决的问题开始时，视图订阅模型。模型为空，视图不显示任何内容。当调用方法时(例如，当用户单击时)，将通过网络发出请求。结果将填充模型，该模型将通知更改的视图。如果另一个视图订阅，则应该使用模型当前值通知它，而不需要通过网络进行任何调用。如果在请求进行期间所有视图都取消订阅，则模型仍将弹出，以便另一个视图可以。

浏览 1提问于2017-06-16得票数 3

回答已采纳

点击加载更多