我对rxJava非常陌生，我想使用Retrofit将两个api调用按顺序链接在一起。但是一直收到这个错误:无法为方法xx的rx.Observable创建调用适配器。下面是我的部分代码：
ServiceA
.subscribeOn(rx.schedulers.Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.flatMap(new Func1<ResponseA, Observable<ResponseB>>
浏览 0提问于2018-07-20得票数 0
1回答
我需要在我的Android项目中编写后续请求。因此，首先发出API请求，当异步响应返回时，在第二个请求中使用响应，依此类推。
我一直在研究RxJava2库，但还没有完全理解。此外，RxJava代码将位于Interactor类中，该类将调用驻留在存储库中的函数，因此我不想直接在RxJava2代码中编写代码，而是从另一个类调用函数。一个涵盖这些领域的GitHub回购将对我非常有用。
浏览 0提问于2018-01-15得票数 0
回答已采纳
问题很简单:如何将Observable<Array<T>>转换为Observable<T>
如果你能用rxJS或RxJava写答案，我会很感激，但是其他语言都是好的。
浏览 2提问于2017-08-04得票数 0
回答已采纳
我使用的是API 2和改进的RxJava库，我想执行700多个查询，每个查询都是一个改进的API调用。
如何在RXJava 2中使用zip运算符实现这一点？
浏览 0提问于2018-04-18得票数 0
1回答
我有两个实体类，它们存储在SQLite中：UserEntity和SessionInfoEntity
public class UserEntity{
private Long id;
private String userName;
// ....
}
public class SessionInfoEntity{
private Long id;
private Date beginSessionDate;
private Date endSessionDate;
// ....
}
用户可以有多个会话(一对多的关系)。
我有一个存
浏览 9提问于2017-03-28得票数 0
回答已采纳
我在我的项目中使用了Rxjava和Retrofit2.0 2.0，看起来像这样：
Observable<List<A>> getAFromServer();
Observable<List<B>> getBFromServer(@Body A.a);
如果我不使用反应式方法，它将是这样的：
List<A> listA = getAFromServer();
foreach(A a: listA){
getBFromServer(a.a)
}
所以，我的问题是如何使用Rxjava来实现这一点，以及使用什么运算符？
浏览 1提问于2016-03-29得票数 2
2回答
我有以下对象结构
class Object1 {
A[] item1; //array of Object A
B[] item2; //array of Object B
C[] item3; //array of Object C
}
class C {
int value1;
int value2;
String imageUrl; //null, to be updated from a api call
}
我得到一个进行修改api调用的Observable<Object>。object C的imageUrl字段是null，我必
浏览 1提问于2015-07-10得票数 0
回答已采纳
我是RxJava的新手。我有几个泽西RxJava客户端返回可观察数据。我需要进行一次调用来获取一些数据，这些数据将成为我接下来的3个调用的输入。我希望这些调用是并行进行的。最后，我想在所有调用完成后进行计算，这需要所有的数据。下面是它的外观：
interface Service {
Observable<ResultA> callServiceA(InitialData input);
Observable<ResultB> callServiceB(ResultA resultA);
Observable<ResultC> callServic
浏览 0提问于2016-07-28得票数 0
我是RxJava的新手，但我喜欢。现在我有了点小麻烦。我使用的是RxJava + Retrofit。
如果我对用户有有效的令牌，我会得到API的响应，但是如果令牌无效，我必须刷新令牌并再次尝试发出请求。
有效令牌：
造真
得到响应
完成
无效令牌：
提出请求
得到响应
If response_code == 403，需要刷新令牌
刷新令牌
在这里，我想转到1步，再次请求API。
Else -完成
如何使用RxJava?制作它
浏览 2提问于2016-12-05得票数 2
回答已采纳
我在类(A)中创建了一个任务，然后异步调用，然后如果任务完成或取消，传递结果另一个类(B)，在rxJava2中使用，在rxJava2中是非常新的，我可以使用这个逻辑吗?I confused.What？可完成的还是可流动的？ 我想做的是 调用异步任务类(B)，运行任务并发出一些结果类(A)，然后在类(B)中订阅任务结果，你有什么想法吗？感谢您的建议
浏览 15提问于2019-01-17得票数 0
回答已采纳
我一直在调整我的安卓应用程序以使用RxJava，但我在这方面遇到了一些困难。正如我在上一篇文章()中所建议的那样，我正在使用可观测数据来模拟我在JavaScript中与REST接口的方式。具体来说，使用诺言库，我编写了如下调用：
$q.all([
fetchResourceA(),
fetchResourceB()
])
.then(function (responses) {
...
return fetchResourceC();
})
.then(function (response) {
...
});
在本例中，我同时查询两个
浏览 1提问于2014-12-09得票数 0
回答已采纳
2回答
场景-为某些项目(假设4个项目)进行服务调用，这将更新数据库。顺序并不重要。所有的服务调用都是相互独立的，但是要等到所有的调用都完成了，所以我想使用rxjava1.x进行并行调用
现在，我面临的问题是，如果更新服务成功，它不会返回任何内容。
public class DbClient {
public void update(SomeObject someObject) {
//update logic
}
}
//client code to call update method
public void processUpdate(Map<String, SomeObj
浏览 1提问于2019-02-25得票数 0
我试图在RxJava中找到一个适合下一个序列操作的操作：
A，B，C -> Aa，Ab，Ac，Ba，Bb，Bc，Ca，Cb，Cc
实际的用途是，我有一个可观察的，包含一个项目的列表，我正试图转换为可观察的发射扁平的项目从列表。
如下所示：
Observable<List<Item>> ---> Observable<Item>
我似乎找不到合适的RxJava操作来执行这样的操作--有flatMap()，它与我想要的完全相反，但没有“生成”或"mapToMany“操作。我遗漏了什么？
浏览 1提问于2014-09-04得票数 1
回答已采纳
我的新闻有List<News>列表.我必须为每个新闻发出异步请求，以获取新闻图像列表(来自API)。
我试着用RxJava做它，但我做不到(
我认为使用该Observable.fromIterable(newsList)，然后使用zipWith(imagesListRequestObservalbe, News, News(with images))，然后使用toList()，但是它是如何在代码中生成的--我不知道。
请告诉我如何用RxJava解决我的问题
浏览 2提问于2017-06-21得票数 0
1回答
我需要获取类别，然后获取该类别的通道，最后在从服务器检索所有类别及其通道时调用一个方法。我想我需要使用RxJava，但是我找不到类似的实现。(最好不使用lambda/retrolambda表达式)。
@GET("/api/{categoryId})
Call<Category> getCategory(@Path("categoryId") String categoryId)
private void getCategories() {
for (Tab t : tabs) {
Call<Category> getC
浏览 1提问于2018-03-23得票数 0
回答已采纳
1回答
我正在学习RxJava几周，我有一些java代码，如下所示
代码：
String[] strings1 = new String[]{"a", "b", "c", "d", "e"};
Integer[] integers = {1, 2, 3, 4, 5};
String[] strings2 = new String[]{"f", "g", "h", "i"};
for (String str : strings1) {
for (Int
浏览 1提问于2017-06-07得票数 1
回答已采纳
我有一个网络调用，其中将返回300个id，我需要为每个id进行一个网络调用，并将结果编译到列表中。我试图使用flatmap来做这件事，但是遇到了问题。
有没有办法定义paral的线程创建数量?有没有人可以给我一个并行执行网络调用的例子，以便在android中使用rxjava1和rxjava2快速得到结果。
这是从片段中获取所有记录的代码：
private void subscribeToStories() {
contentValues.clear();
if (isOnline()) {
//Provider provider = Inject.provide
浏览 1提问于2018-03-09得票数 0
我正在处理批处理作业，它读取、转换和写入文档到coucbase。我正在使用Java批量插入文档。我不想使用upsert，因为我想在文档已经存在于couchbase中并调用insert时进行日志记录。请在下面找到我的代码。当文档已经存在时，将抛出DocumentAlreadyExistsException并停止作业，而不是继续处理下一个文档。如何处理这个问题？ 代码： public void insertAll(Collection<JsonDocument> documents) {
Observable.from(documents).flatMap(new
浏览 38提问于2019-05-11得票数 2
回答已采纳
我是个新手，没有接触过retrofit和rxjava。我正在尝试使用这两种方法实现一个非常常见的用例，但是找不到合适的运算符。用例-我正在进行API调用，以检查我的访问令牌是否有效。如果它不再有效，我将得到401未授权异常，此时我想进行一个API调用，以使用刷新令牌来获取新的访问令牌。注意-两个API请求的响应类型不同。 我如何使用retrofit和rxjava实现这一点。 我试着用flatMap，onErrorResume来实现它，但是找不到最好的方法。
浏览 24提问于2019-05-16得票数 0
我试着用RxJava + Retrofit + Kotlin来学习链式请求。我正在学习的教程是使用RxJava 1.x，所以当我尝试用RxJava 2.x重新实现时，我无法让.zip()工作。
这是一个简单的应用程序，使用星球大战API，返回一个电影列表，安藤为每部电影，从他们的字符。
fun loadMoviesFull(): Observable<Movie> {
return service.listMovies()
.flatMap { filmResults -> Observable.from(filmResults.results
浏览 5提问于2017-06-25得票数 0
我试图使用Vertx工具链、RxJava库和Scala语言实现简单的websocket处理。
将匿名类传递给RxJava map方法时出现错误
websocket
.flatMap(socket => socket.toObservable)
.map(new Function[Buffer, String] {
override def apply(msg: Buffer): String = {
msg.toString
}
})
编译器堆栈跟踪：
Error:(61, 6) no type parameters for
浏览 50提问于2018-10-09得票数 0
回答已采纳
1回答
我是RxJava的新手，我正在用RxJava2做一些RESTful编程。我没有几个API调用，它们都是相互独立的。我从我的用例中观察到的是，由于API调用是异步的wrt，并且都是返回Observables<String>，而从所有的API响应中我正在进行一些计算，所以在计算时，我还没有从几个API中得到响应，因此它失败了。对于所有尚未收到响应的API，我使用的subscribe代码如下所示：
Observable<String> res = someApiCall(data1,data2);
res.subscribe(data -> { //Call Anoth
浏览 0提问于2018-02-13得票数 2
回答已采纳
我使用Retrofit 2，我正在学习RxJava。我从某个地方下载了一个项目列表。我希望对每个项目进行api调用，并创建一个新的扩展项列表。两个电话都返回一个可观察到的。看起来是这样的：
getItemsService.getItems()
.concatMap(Observable::from)
.map(item -> new ExtendedItem(item, someOtherService.getDetails(item.somedetail)))
.toList()
.subs
浏览 2提问于2016-04-05得票数 3
回答已采纳
1回答
如何处理项目列表的多线程加载。我从api列表中获取字符串元素。下一步，需要获取此列表中项目的数据。加载需要使用rxjava。结果需要做的就是获得单个订阅。
浏览 3提问于2018-10-18得票数 0
我正在尝试执行以下操作:使用Retrofit将云DB同步到设备上的本地SqLite DB (Room)。数据库可能会变得很大，大约100,000个寄存器，或者更多，所以同步过程可能需要一些时间。因此，它首先发送一个重放请求来获取寄存器的数量，这样就可以计算出总页面数，然后再发送多个重放请求，从API获取所有数据，每次请求后，将数据保存到Room。
现在，我很难组合两个RxJava调用或进程，也是在第二个RxJava进程上，在重新配置调用之后，有一个由表列表组成的Room插入，但是在空洞处理结束后，我注意到并不是所有记录都被插入，每次我运行进程时，插入的记录数量都会发生变化，大约是80% - 9
浏览 1提问于2020-05-09得票数 3
回答已采纳
RxJava Kotlin平面映射不返回分隔字符串中的分隔对象。相反，它返回列表。
val source: Observable<String> = Observable.just("521934/2342/FOXTROT")
.flatMap{Observable.fromArray(it.split("/"))}
.subscribe{Log.d(TAG, "$it")}
它返回列表：
[521934, 2342, FOXTROT]
但是书(Thomas : Learning RxJava / 2017 /Page114)说它必须
浏览 3提问于2017-09-27得票数 3
回答已采纳
首先，我以前从未使用过RxJava。我必须实现一个开发工具包，这是使用AndroidRx或RxJava的所有用例和提供的例子。
我有以下从后端返回数据的方法
override suspend fun getSomeData(token: String): Outcome<String, DataError> {
val getSomeDataMutation = GetSomeDataMutation(token)
try {
val response = apolloClient.mutate(getSomeDataMut
浏览 17提问于2021-02-27得票数 0
在RxJava2中，flatMap()和flatMapIterable()有什么区别？
flatMapIterable()背后的逻辑是什么
浏览 1提问于2018-02-05得票数 2
3回答
我试图找出如何接收一个返回项目列表的响应，然后对每个返回对象的项目提出请求，然后将所有响应合并到一个列表中。
我一次只发出一个，就能让它正常工作，但我想把它们都打包回列表中。
到目前为止我有这个
getListOfData()
.flatMapIterable(list -> list)
.flatMap(item -> getData(item)
我已经尝试过toList()，但我知道这需要一个完整的信号才能返回任何内容。
我使用的是rxjava 2，我觉得我在rxjava 1中用toList()完成了这一操作，并且它按照预期工作。任何帮助都将不胜感激！
浏览 5提问于2017-02-24得票数 2
回答已采纳
1回答
如何让Observable<ArrayList<user>>中的每个用户在订阅之前与其他可观察到的用户进行处理。我在堆栈溢出上搜索了它，并让它了解了flatMapIterable()，但是它仍然不是working.How，我会在Rxjava2中这样做吗？请告诉我谁..。
浏览 0提问于2018-01-30得票数 0
回答已采纳
我正在研究我的安卓应用程序中的Retrofit2。
我的gradle.build类似于：
retrofit2Version = "2.4.0"
rxAndroidVersion = "2.0.2"
rxJavaVersion = "2.1.12"
okhttp3Version = "3.10.0"
implementation "com.squareup.okhttp3:logging-interceptor:$okhttp3Version"
implementation "com.squareup.r
浏览 3提问于2018-07-09得票数 2
2回答
总的来说，我对RXJava还比较陌生(实际上只是在RXJava2中才开始使用它)，而且我可以找到的大多数文档都是RXJava1；现在我通常可以在两者之间进行转换，但是整个反应式的东西都是如此之大，以至于它是一个强大的API，有很好的文档(当您可以找到它时)。我正在努力简化我的代码，我想用婴儿的步骤来完成它。我想要解决的第一个问题是，我在当前的项目中做了很多工作：
您有一个请求，如果成功，您将使用该请求进行第二个请求。
如果这两种方法都失败了，您需要能够识别哪一个失败了。(主要用于显示自定义UI警报)。
我现在通常是这样做的：
(为了简单起见，省略了.subscribeOn/observeOn
浏览 6提问于2017-04-11得票数 12
回答已采纳
1回答
下面是我要做的事情的简化版本(使用Kotlin和RxJava)
makeServerCall()
.doOnNext {
doStuff(it)
}
//TODO: if it == 0, call asyncOperation() and wait for its callback to fire
//before running the rest of the stream. Otherwise immediately r
浏览 2提问于2017-09-14得票数 1
回答已采纳
我正在构建一个由两个API调用组成的应用程序。我还在学习RxJava，我不知道如何正确地组合这两个API调用
第一个API调用用于以列表的形式检索项，第二个API调用用于使用我从第一个调用获得的项名检索项目映像。
我需要显示所有的项目与他们的图像。这些都是我使用改装的API调用。
@GET("items/list")
fun getItems(): Observable<ItemResult>
@GET("item/{name}/images")
fun getItemDetails(@Path("name") name: Stri
浏览 2提问于2019-10-08得票数 0
回答已采纳
1回答
使用RxJava的嵌套网络请求
、、、、
我对RxJava非常陌生。我在将嵌套的异步操作转换为RxJava结构时遇到了问题。创建一个从服务器获取数据的异步任务并不是问题，但是我对这种典型案例有一个问题：
List<A> aaa = new ArrayList<>();
List<B> bbb = new ArrayList<>();
new FetchItemA(String id){
@Override
protected void onPostExecute(List<A> items){
foreach(A item:items){
浏览 1提问于2017-09-08得票数 1
我正在使用带有AndroidFastNetworking库的RxJava。如果我想使用Scheduler类创建一个每隔60秒初始化一次Http请求的可观察对象，但我想让它等待初始化的请求完成(成功或错误)，然后再次启动60秒的间隔并初始化下一个间隔，那会是什么样子？
浏览 17提问于2019-03-29得票数 1
我是RxJava的新手。我目前正在修改一个现有的同步流，并使用现有方法的返回观察值使其成为异步的。
在其中一个流程中，我进行了一个远程调用，以从DB接收一个项目。由于对数据库的调用是异步的，因此会返回一个可观察对象。但是，数据库中可能不存在该项，在这种情况下，该值将为NULL。
如果该值为NULL，我需要对各种其他远程服务进行额外的异步调用，并最终返回可观察到的响应。
我不明白的是如何用RxJava实现这样的流程。下面是一个伪代码示例：
void searchSomethingAsych(String key) {
Observable<SearchResult> res
浏览 6提问于2016-07-27得票数 0
回答已采纳
如何实现与flatMapFirst类似的flatMap运算符，但只在前一个操作符结束时才增加新的可观测性？如果前面的那个还在运行，它就会忽略新的可观察到的。如何在RxJava 2中实现？
它已经存在于培根- 和kefir - 中.
浏览 9提问于2017-01-24得票数 1
回答已采纳
我有两个使用RxJava执行的请求。他们应该一个接一个地跑。这是我目前所拥有的：
fun showPhotos() {
_liveData.postValue(Resource.Loading())
compositeDisposable.add(useCase.getPhotos()
.subscribe({
showPosts(it)
}) {
_liveData.postValue(Resou
浏览 30提问于2020-03-04得票数 1
回答已采纳
我们如何使用RxJava同步两个异步调用？在下面的示例中，作为应用程序接口调用的方法contentService.listContents必须首先在processSchema方法之前完成，才能对每个模式进行操作。
schemaService.listSchema()
.toObservable()
.flatMapIterable(schemas -> {
schemas.forEach(schema -> {
// async call
contentService.listContents(sche
浏览 0提问于2020-01-21得票数 1
1回答
我对RxJava非常陌生，并在安卓系统中使用它。
在我的演讲者中，我试图使用RxJava获取名为“赋值”的数据。
算法非常简单，检查是否有本地赋值存储，如果没有从远程服务器获取，然后尝试从本地再次获取。
目前，它所做的是从远程服务器获取，如果本地sqlite返回0结果。我希望它只从本地sqlite返回，例如，如何使它再次调用mRepository.query(new AssignmentSpecification.class)并只返回它？
更新为当前解决方案
restartableLatestCache(REQUEST_ASSIGNMENTS,
() -> {
浏览 0提问于2017-01-09得票数 0
2回答
你好，RxJava大师，
在我当前的Android项目中，我在使用RxJava和SQLite时遇到了一些死锁问题。我的问题是：
我在线程上启动一个事务。
调用web服务并在数据库中保存一些内容
concat映射另一个可观测函数
尝试在数据库上编写其他内容
这是我的代码：
//define a scheduler for managing transaction in the same thread
private Scheduler mScheduler = Schedulers.from(Executors.newSingleThreadExecutor());
浏览 2提问于2016-07-06得票数 4
1回答
我对RxJava的概念还很陌生。我想要链接一些调用：
Observable<RoomList> listRoomsCall = mRoomServiceApi.listRooms();
//此调用将获取RoomIds下一步是在请求之后调用所有RoomIds - request
mMeetingServiceApi.listMeetings(roomID, startsAtString, endsAtString, free))
我应该如何将第一个调用和下一个调用链接起来？
我想我应该使用flatMap和循环来调用所有的请求，但是如何在最后连接所有的响应呢？
listRoomsC
浏览 16提问于2017-12-18得票数 1
回答已采纳
在我的应用程序中，我使用的是改造和RxJava。我正在执行一个请求，它将每1秒访问服务器一次。为此，我使用请求params创建了更新服务API，并在返回的可观察对象上订阅并使用repeatWhen。
问题是，每次命中请求时，我都希望更改与请求一起发送的请求参数(基本上必须使其动态)。我怎样才能做到这一点？
例如，用例: sendLocation Api每10秒向服务器发送当前位置。如何利用改造和RxJava来实现这一点？
浏览 6提问于2016-12-12得票数 3
回答已采纳
我希望能够将我对服务器的调用限制在每秒20次。否则服务器会将我的IP列入黑名单。
我如何使用rxjava和retrofit来实现这一点呢？有没有一个简单的函数？
否则，我如何告诉订阅上的观察者在进行服务器调用之前等待n秒？
浏览 4提问于2017-03-27得票数 2
有一个例外，它反复出现在我的应用程序的Crashlytics(Fabric)上。我使用rxjava2进行http调用。
这就是crashlytics日志中的所有内容(如下所示)。会非常感谢你的帮助的/insights。
Fatal Exception: io.reactivex.exceptions.UndeliverableException: retrofit2.adapter.rxjava2.HttpException: HTTP 404
at io.reactivex.plugins.RxJavaPlugins.onError(RxJavaPlugins.java:349)
浏览 1提问于2017-09-19得票数 4
我希望使用RxJava进行长时间操作，同时不阻塞在订阅方法(或其他方式)上使用它们。longOperation()只是在DB中保存值，所以它不会影响值本身。我有以下代码：
Observable.interval(1, TimeUnit.SECONDS)
.doOnNext {
value -> longOperation(value)
}
.subscribe {
finalConsumer(it)
}
如何使它是异步的？
谢谢。
浏览 2提问于2018-05-26得票数 2
回答已采纳
所以这个场景是我们需要进行2次改造调用的场景，
@GET("/")
Observable<Search> searchMovies(@Query("apikey") String apiKey, @Query("s") String searchKey);
@GET("/")
Observable<Details> getMovie(@Query("apikey") String apiKey, @Query("t") String searchKey);
第一个方法是获
浏览 4提问于2017-07-04得票数 0
RxJava 2.0.5引入了ParallelFlowable类型，对应于Flowable.parallel()操作符。我发现实现并行性的一般建议是使用flatMap，如下所示：
Flowable.just(1,2,3)
.flatMap(x -> Flowable.just(x)
.observeOn(Schedulers.computation())
.map(y -> y + 1))
.forEach(System.out::println);
什么时候使用flatMap来并行比较合适，什么时候使用ParallelFlowabl
浏览 1提问于2017-05-31得票数 8
回答已采纳
在RxJava1中，flatmap有一个重载方法，允许您保留源值并将其向下传递。
我从下面的博客文章中获得了这些知识
然而，移动到RxJava2，我似乎找不到它。我检查了Rx1和Rx2的更改，但没有列出。我想知道它是否仍然存在，但我可能找错了地方。
顺便说一下，我正在使用Single。
浏览 0提问于2018-02-09得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
