rx-android

1热度

2回答

我刚刚开始使用RxJava/android并开始练习并开始使用我希望使每个1秒都能发出字符串的字符，我该怎么做？以下是我迄今为止尝试过，它只是发出串一次： Observable<String> myObservable = Observable.interval(5000L, TimeUnit.MILLISECONDS) .observeOn(AndroidSchedulers.ma

0热度

1回答

RxJava：范围运算符不工作

为了实践目的，我创建了stream/Observable，它以1秒周期发射值，其发射值以一秒为间隔，但在发射6后不会终止/停止，它会继续发射值。 Observable myObservable = Observable.range(1, 6) .interval(5000, TimeUnit.MILLISECONDS) .observeOn(AndroidSchedul

0热度

1回答

RxJava：如何使可观察的创建不同于主线程的线程

我想要可观察的代码在不同于主线程的线程上运行。我怎样才能做到这一点，我在做这样的： Observable operationObservable = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter e) throws Excep

2热度

1回答

字符串值如何传递给updateText（）方法？

与RxJava修修补补的第一次，我已经创建了一个的Rx链听在String对象的状态的变化： observable=Observable .defer(new Callable<ObservableSource<String>>() { @Override public ObservableSource<String> call() throws Exception {

0热度

2回答

使用observables改进并行响应处理

我正在开发一个应用程序，用户可以在注册后编辑他/她的配置文件。问题是编辑配置文件时会对后端使用多个API调用。一个用于编辑电子邮件，一个用于编辑密码等等。我将retrofit2与RxJava结合使用，因此呼叫是Observables/Singles。当用户按下编辑按钮并在不同线程上执行调用时，会显示一个微调器。如果它们并行执行，我该如何处理成功/失败？用户需要知道编辑是否成功，并在呼叫完成时隐藏微

1热度

1回答

RxJava：知道什么时候可观察完成并返回布尔值可以对调用者进行查看

我是RxJava的新手。我的经验主要来自那些教程： Here和here。现在，我发现自己处于一种与Retrofit2进行API调用的情况，该调用将返回Obesrvable<AccessToken>。客户端将如下调用这个服务： public Observable<TokenResult> authenticateWithClientCredentials() { return auth

0热度

2回答

使用RxJava2在ViewModel上进行EditText验证

我试图在单击按钮时使用RxJava对EditText执行验证，但是我很难将验证移动到ViewModel，这会使测试变得更容易。我使用Jake Wharton的RxBindings来获取UI输入，并使用PublishSubject的RxJava2的Flowable.combineLatest在单击AlertDialog上的按钮时触发Flowable。这是我走到这一步： private Flowabl

1热度

2回答

如何找到配置文件的内存泄漏

我已经抛弃了大量的内存，并发现存在内存泄漏。如果你看截图，你会看到只有一个片段，但有9个相同类型的演示者。应该只有一个。当我检查一个演示者实例时，分析器向我显示对演示者的引用。这些都是RxAndroid方法的回调方法。我正确地取消了在片段的onDestroyView中的所有这些。不过，演示者实例并未被清理（如您所见）。所以我想知道如何区分有效（循环，内部）引用，它仍然存在，因为对象仍然没有垃圾

1热度

1回答

如何在flatMap运算符中正确查询？

我从服务器获取json格式的聊天列表。我把他们推到ChatsModel。此类中有userId字段，即在每个聊天中有该用户的userId。没有关于用户的其他信息。还有就是有关类型的用户信息的一个领域UserMessagesResponse 所以，在那个userMessagesResponse等于null 我聊天列表和userId之后开始时，我要送另一个请求获取有关信息用户。我这样做，是这样的：发生在

0热度

1回答

如何使用RxJava 2使用onResume（）和onPause（）方法来订阅和取消订阅？

那么，我需要绑定发射到我的活动的生命周期。我怎样才能做到这一点？何时应创建观察者和可观察的实例？