rx-java

0热度

1回答

Kotlin：如何将使用Thread.sleep的测试转换为RxJava TestScheduler

我正在编写一个工具测试，它检查是否将某些东西缓存到Rx缓冲区中，并且在某段时间（10秒）后，此Subject将缓冲值插入到我的房间数据库。当我使用Thread.sleep（syncTimeInterval）时，测试是正确的。我想用TestScheduler编写相同的测试。这是用了Thread.sleep版本（通过测试）： @Test fun testMultipleLogs() {

0热度

2回答

保持区间可观察运行中的Java

我新用Java线程，并想知道我怎么能牢记以下可观测运行， private void init() { System.out.println("Running..."); Observable o = Observable.interval(5, TimeUnit.SECONDS) .flatMap(o -> serverService.listServers("

0热度

1回答

RXJava逻辑图链

我有以下代码写在RXJava中。 validateProduct(payload) .map.(r -> { if(r.getBoolean("valid")){ return createProduct(productPayload); }else{ return null; // request.end() | end the chain here

1热度

1回答

的DatePicker与数据绑定和Rxjava可观测视图不保存到境界上不同的Android版本

下面运行该代码与Android版本SDK 16.但是一个机器人仿真器以某种方式，当它运行在与Android版本> 21，数据绑定与境界模拟器储蓄不被触发.. 我应该如何与Android版本来处理？是因为所呈现的UI在不同的Android版本不同，所以数据绑定不会有任何的工作？这里这段代码视图模型 @PerFragment public class OnboardDOBViewModel ex

0热度

1回答

从AsyncTask到RxJava的改造请求周期

如何从AsyncTask（从doInBackground方法）将以下代码更改为RxJava？ MessageRq rq = new MessageRq(); rq.setId(id); Call<MessageRs> response = App.getApi().getFirstCommand(rq); nextLink = getNextUrl(response, rq); for (

0热度

1回答

使用实时数据更新Recycler视图

我有一个实时更新对象的列表（每秒一次）。我已经设计我的应用程序使用MVVM架构和Android数据绑定库我已经将视图模型绑定到视图，并且每次重新加载活动时都会更新正常，但无论如何都要通知视图模型该模型数据已经更新并且实时更新视图？我已经尝试过实现BaseObservable接口和ObservableFields，但我仍然得到相同的结果。可能还有一些RxJava技术，我可以用我虽然不熟悉RxJ

2热度

1回答

使用反应流的无源拉式背压

这是我对该主题的理解。有出版商和订阅者。为发布者和订阅的伪码是一样的东西， Publisher{ Subscriber s; subscribe(Subscriber s){ this.s = s; s.onSubscribe(new Subscription(){ onRequest(int n){ List<Mess

1热度

2回答

如何使Observable在1秒的时间间隔后发出字符

我刚刚开始使用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