rx-android

1热度

1回答

林新与Rxjava，在这里我的代码 class RadioListRepositoryImpl(private val apiServices: ApiServices, private val chlDao: ChannelDao) : RadioListRepository { private val results: MutableList<DataResponse> init {

-2热度

1回答

获取状态代码RX + Retrofit2 - Android电子

我连接到服务器，其中Rx + Retrofit2像波纹管： @Override public void fetchListLanguage(RemoteDataSource.ResultListener<Languages> resultListener) { RetrofitApi retrofitApi = new RetrofitApi(); PublicApi pub

5热度

2回答

内存不足错误RxAndroid + RxJava + Retrofit2

我是使用RxAndroid和RxJava的新手。我正在使用RxJava + Retrofit2来发出GET请求。我正在做大约1500 GET请求使用下面的代码并出现内存不足错误。然而，这次只使用改进的代码，没有RxAndroid，它的工作原理。所以我的结论是我在RxAndroid上做错了什么。你能帮我解答一下吗？代码示例： Subject<Story> mStoryEmitter = Publi

0热度

2回答

使用rxjava的列表的索引总和

我有一个数组列表的列表。主列表中的每个列表都包含恒定数量的项目。（在每个数组列表中说3个项目）。我想要做的是我需要获得每个列表的索引总和作为一个新的列表。例如，如果我的主列表包含数组列表像 1, 2, 3 1, 2, 3 1, 2, 3 然后我得到的名单应该是 3, 6, 9 和我有只RxJava做到这一点。由于我对RxJava非常陌生，所以我很困惑我应该

1热度

3回答

RXAndroid：可观察等待另一个可观察的完成

我正在使用Retrofit和RxAndroid。现在我想调用api来获取用户信息，然后使用这些信息作为参数来调用另一个API来获取更多信息。我该怎么做才能达到这个目的？ P/S：它可以回调做，但我想与RX-Android的风格

0热度

1回答

RxJava2在调用complete或error时会自动处理observable吗？

我对RxJava的处置有疑问。我在Github上的RxSwift文档中找到了下面这句话。当一个序列发送completed或error事件时，所有计算序列元素的内部资源都将被释放。要立即取消序列元素和空闲资源的生产，请在返回的订阅上调用dispose。如果我理解正确，资源（观察对象）将在他们拨打onCompleted或onError后被释放。所以问题是，RxJava和RxSwift做的一样吗

0热度

3回答

只有在第一次触发时才会合并2个观察点

对于Rx我很新，我有一种情况是我没有找到任何关于（或者我没有提出正确的问题）。我有一个可触发的应该触发一个特定的方法。不过要调用这个方法，我需要第二个可观察值（它会在第一个值之前总是有这个值）。我该如何结合这两种方法才能在第一个可观察到的火灾发生时才调用该方法？这就像combineLatest一样，但是如果任何一个Observables发射，那么就会发射。 Br， Daniel

0热度

1回答

Rx-Java Retrofit没有得到任何回应

我正在尝试做一个示例Rxjava-Retrofit应用程序。我有获取从OpenWeatherMap 我改造的API接口看起来像这样 public interface ApiInterface { @GET("data/2.5/weather?appid=11111111111") Observable<WeatherData> getWeather(@Query("q") St

-3热度

1回答

如何取消订阅RxJava2中的可观察或订阅？或者我真的需要吗？

如何取消订阅RxJava2中的可观察或订阅？或者我真的需要吗？ //Initialising Obersvable Observable<SearchSuggestions> observable = NetworkContext.api.getSearch(""); //subscribing obersvable on another thread and obser

2热度

1回答

RxJava Android序列打印数据

我在Android中学习RxJava。我： Observable<Country> getCountries(){} // returns Countries Observable<City> getCapital(int countryId){} // returns capital by country id 我想：打印用的getCountries返回的所有国名（）。然后从getCa