rx-java

0热度

1回答

我试图找到一种并行执行请求的方法，并在每个observable完成时处理它们。尽管所有的观察对象都给出了回应，但所有事情都能正常工作，但在完成所有事情时我没有办法处理所有的错误。这是拉链运算符，它基本上并行地执行2名的请求的示例： Observable.zip( getObservable1() .onErrorResumeNext { errorThrowab

0热度

1回答

用于RxJava的泛型Observable的TestScheduler

我开始使用TestScheduler。如果我用这个代替 @Test public void test1() throws Exception { //when TestScheduler scheduler = new TestScheduler(); TestObserver<Long> subscriber = new TestObserver<>();

0热度

2回答

如何使用RxJava获得来自Realm的物品列表的Observable？

我只有这个： public Observable<List<Movie>> getAll() { return Observable.just(Movie.class) .flatMap(t -> Observable.just(t) .doOnSubscribe(disposable -> realm.executeTransaction(realm1

-1热度

2回答

RxJava Single.create无法指定线程

在initialize（）方法的下面工作很好，但它必须与其他调用在同一个io线程（ioScheduler）上工作。 fun initialize(): Single<Boolean> { return Single.create { callback -> callback.onSuccess(true) } } 我试图将其更改为下面的代码： intern

0热度

1回答

Asynctask status &&取消等效于RxJava2 Observable？

我想学习RxJava2，并将我的AsyncTasks转换为Observable。我有下面这段代码，我试图转换。 if(asyncTask.getStatus() == AsyncTask.Status.RUNNING){ asyncTask.cancel(); } asyncTask = new CustomTask(); asyncTask.execute(input);

0热度

2回答

将RxJava代码正确转换为Kotlin

我正在学习Kotlin和RxJava。我在JAVA这样的代码： public class MainActivity extends AppCompatActivity { private HashMap<String, Object> cacheToInsertToDb; @Override protected void onCreate(Bundle savedInstanceSta

0热度

2回答

RxJava 2运营商组合，只提供第一个值从一堆

这个想法是，当我多次呼叫publishSubject.onNext(someValue)我只需要得到一个值，如debounce运算符，但它提供了最后一个值，我需要跳过所有值除了第一组之外，直到我停止呼叫onNext()持续1秒。我试过使用类似throttleFirst(1000,TimeUnit.MILLISECONDS)的东西，但它不像debounce那样工作，它只是在每次交付后使窗口和1秒后

0热度

1回答

RxJava-JDBC中的批量插入

我有一个要插入数据库的数据列表。我目前使用RxJava-JDBC的解决方案如下面的代码片段所示： String sql_batch_insert = "insert into ... values(?, ?); Observable<List<..>> data = ...; data.flatMap(list -> Observable.from(list) .flat

2热度

1回答

Observable.just VS单在RxJava

我是新来RxJava和RxAndroid，并试图了解Observable.just和Single之间的差异。它看起来每个都被设计为为其观察者发射一个项目。这里是我的简单的Android活动的有两个按钮的代码。第一个按钮创建一个Observable，第二个按钮创建一个Single： findViewById(R.id.just).setOnClickListener(view -> Observa

0热度

2回答

与多个用户一次呼叫流的一部分？

我有用于套接字通信的自定义Rx适配器。在它之外，我观察到Flowable带有消息。然后我有一些经理处理每个消息，然后进一步发布它。 fun observeSocket() = socketManager .observe() .doOnNext{ insideMessageHandler.handle(it) } 然后，我