reactivex 相关问题

ReactiveX是一个库，用于通过使用可观察序列来编写异步和基于事件的程序。

我使用的是Python 3.7.3。我尝试将RxPy从1.6.1（1.x）升级到3.0.0a3（3.x）。从rx import使用RxPy 1.x的旧代码Observable import psutil import numpy as np import pylab as plt cpu_data =（...

python python-3.7 reactivex rx-py

回答 2 投票 0

可观察的可观察数组 - 如何在RxJS中实现？

我刚刚第一次学习RxJS，所以如果这个问题基于错误的假设，我会道歉。比如说，我在我的Angular应用程序中有一个返回数组的FooService ....

angular rxjs observable reactivex

回答 1 投票 0

什么是RXJava及其用途？

告诉大家，我已经在互联网上阅读了一些关于RxJava的文章，以便更好地理解它是什么，但我仍然觉得它很难理解.Culd任何人都建议我：...

rx-java reactive-programming reactivex

回答 1 投票 0

ReactiveX - 单身单身

我正在寻找一个采用干净架构方法的示例项目，并且我在将单个转换为另一个时遇到了一些困难。我有我的改装服务（单人）：@GET（“nearbysearch / ...

rx-java retrofit2 reactivex clean-architecture rx-kotlin

回答 1 投票 0

在Akka Streams可观察到延迟

我来自ReactiveX，我们有运营商推迟，以便创建一个Observable并在我们有订户后获得排放值。在Akka Streams，我想知道是否......

akka rx-java observable akka-stream reactivex

回答 1 投票 2

RxJava合并去抖动而不是去抖动可观察者

我有两个observable：Observable O（open）：在textview中打开一些内容的文件Observable E（编辑）：在textview中编辑的文件内容我想去抖E observable，并将它与O合并...

java rx-java reactivex

回答 2 投票 8

递归可观察

我正在使用RxJs，我必须建立一个轮询机制来从服务器检索更新。我需要每秒发出一个请求，解析更新，发出它并记住它的id，因为我需要......

rxjs reactivex

回答 1 投票 2

我的Retrofit / ReactiveX方法是否实际异步检索数据？

swipeRefreshLayout.setOnRefreshListener（（） - > {swipeRefreshLayout.setRefreshing（true）; retrieveData（mCardAdapter，db）;}）;由于某种原因，以下方法阻止了我的主UI线程，...

java android rest retrofit reactivex

回答 1 投票 1

RxPy读取csv文件和进程行

我想使用RxPy打开（csv）文件并逐行处理文件。我确实设想有以下步骤为流提供文件名逐行打开文件读取文件...

python reactivex

回答 1 投票 1

RxSwift - 使用Observable自动重新加载UITableView

我有一些主要的UITableView，其中一些Todos被填充使用了一个Observables数组：//在viewDidLoad self.todosViewModel.todos.asObservable（）。bind（to：tableView.rx.items（cellIdentifier：“...

ios uitableview reactive-programming rx-swift reactivex

回答 1 投票 1

RxSwift - 验证文本字段是否已聚焦

我有一个UITextField，并希望每当它集中时执行一个动作。这是RxSwift可以管理的东西，还是我必须以旧的方式这样做？

ios swift reactive-programming rx-swift reactivex

回答 1 投票 1

RxJs：可观察搜索结果的模式

我的场景是一个带有搜索表单和结果列表的经典网页。我想封装在Observable中加载结果的行为。以下是我目前在TypeScript中所做的事情：......

rxjs reactivex

回答 1 投票 1

如何记忆Single发出的值？

假设我有一个昂贵的计算来创建一个对象。我想通过subscribeOn（）为调用者提供一些灵活性，以确定发生的位置。但我也不想让这个计算更多......