2回答
我最近在我的项目中添加了 SDK；但不幸的是，我不能再使用RxJava了，它会导致重复的异常。值得一提的是，在将SDK添加到项目之前，一切都正常工作。
下面是堆栈跟踪：
Duplicate class io.reactivex.BackpressureStrategy found in modules rxjava-2.0.4.jar (io.hengam.lib:rxjava:2.0.4) and rxjava-2.2.9.jar (io.reactivex.rxjava2:rxjava:2.2.9)
Duplicate class io.reactivex.Completable foun
浏览 4提问于2020-03-24得票数 2
回答已采纳
我有一个像这样组织的Single流：
getSomething() // returns Single<>
.flatMap(something -> {
// various things
return Single.defer( () -> {
// various other things
return Single.<SomeType>create(emitter -> {
// some more stuff
someCallbackApi(result -> {
浏览 19提问于2022-01-11得票数 1
回答已采纳
在中是这样规定的：
默认情况下，可观察对象的运算符的缓冲区大小为128个元素(请参阅Flowable.bufferSize()，可以通过系统参数rx2.buffer- 全局覆盖该大小)。
我的问题是，如何访问和设置rx2.buffer-size？如果我这样做了：
import io.reactivex.Completable;
import io.reactivex.Flowable;
import io.reactivex.Observable;
import io.reactivex.Scheduler;
import io.reactivex.Single;
import io.rea
浏览 80提问于2018-10-24得票数 0
最近，我开始收到这样的事故。没有任何东西被更新为有吊带。有没有人知道是什么引起了这个问题？谢谢。
com.squareup.retrofit2:retrofit:
retrofitVersion =2.6.1；retrofitConverterGsonVersion = "2.6.1"；retrofitAdapterRxJava2Version = "2.6.1"
Dns.java line 39
okhttp3.Dns$1.lookup
Fatal Exception: io.reactivex.exceptions.UndeliverableExc
浏览 0提问于2019-09-17得票数 4
我正在学习RxJava(如果这个问题太基本的话，很抱歉)，而且我在错误处理机制方面有困难(我已经通过了docs，但这是我需要掌握的)。
这是我的密码
public static void main(String[] args) {
Observable<String> source = Observable.just("Alpha", "Beta", "Gamma", "Upma", "Idly");
Observer<String> myObserver = new Obs
浏览 1提问于2019-02-26得票数 3
回答已采纳
我在一个可流动的程序中抛出了两个异常，并使用onErrorReturn来捕获这些异常。但我发现只有第一个例外被抓住了。如何捕捉所有的例外？
Flowable.create(emitter -> {
emitter.onError(new Exception("error1"));
emitter.onError(new Exception("error2"));
}, BackpressureStrategy.MISSING)
.onErrorReturn(e -> {
System.o
浏览 0提问于2018-04-18得票数 0
回答已采纳
据我所知，RxJava2 values.take(1)创建了另一个可观测的元素，它只包含原始可观测元素中的一个元素。哪个不能抛出异常，因为它被take(1)的影响过滤掉，因为它已经发生了第二次。
如下面的代码片段所示
Observable<Integer> values = Observable.create(o -> {
o.onNext(1);
o.onError(new Exception("Oops"));
});
values.take(1)
.subscribe(
浏览 25提问于2017-04-20得票数 41
回答已采纳
我试图使用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
回答已采纳
我有一个这样简单的程序：
public class MainApp {
public static void main(String[] args) {
getAcronyms()
.flatMap(Observable::fromIterable)
.flatMap(MainApp::getTitle)
.filter(Objects::nonNull)
.subscribe(System.out::println);
}
浏览 2提问于2017-05-01得票数 1
回答已采纳
下面有一个示例程序复制了我的问题。
问题：
将flatMap变换应用于某些Observable
订阅上述Observable，将订阅存储在某个地方
在Observable自然终止之前处理上述订阅
在映射器函数返回的Observable中，引发一个Exception
Flatmap操作符不知道如何处理Exception，引发它，程序崩溃/退出
优先/预期行为：
错误应传播到我的onError处理程序，而不是在调用RxJavaPlugins#onError时使程序崩溃。
罪魁祸首是在ObservableFlatMap中找到的下面的代码片段。问题是，一旦父程序
浏览 6提问于2017-09-30得票数 2
我需要从Api获取每个列表元素的数据，还需要实现Internet连接检查器。
然后程序启动一切都很好。
我在现场禁用互联网，并再次运行方法(使用swipeRefreshLayout)，我收到InternetErrorToast，太棒了！
我在现场恢复互联网，并再次运行方法(使用swipeRefreshLayout)，应用程序崩溃，错误。
现在我有了下面的方法。注意！dataManager.getCityConditionsResponse()返回单个
@Override
public void updateCitiesList() {
List<City>
浏览 0提问于2018-10-12得票数 1
回答已采纳
1回答
在我看来，RxJava没有提供很好的异常跟踪。
一个例子是我在运行单元测试时从Eclipse得到的。目前还不清楚使用map函数的是哪段代码。
有什么特殊的技巧来提高追踪能力吗？或者这被认为是一个bug？
2017-02-28 19:12:44/SGT INFO c.bt.nmdb.ndac.adapter.Bnmpv5Adapter : Current time stamp - Tue Dec 23 23:56:00 SGT 2014
2017-02-28 19:12:45/SGT TRACE c.bt.nmdb.ndac.adapter.Bnmpv5Adapter : @f
浏览 2提问于2017-02-28得票数 2
1回答
micronaut中的自定义全局异常
public class GlobalException extends RuntimeException{
}
@Produces
@Singleton
@Requires(classes = {GlobalException.class, ExceptionHandler.class})
public class GlobalExceptionHandler implements ExceptionHandler<GlobalException, HttpResponse> {
@Override
public Http
浏览 6提问于2021-07-13得票数 1
回答已采纳
0回答
我的代码中有以下Rx链：
public Single<List<Items>> dispatchStuff(){
return mRepository.getList()
.filter(list -> list.size() != 0)
.flatMapSingle(mRepository::operateOnList())
.doOnSuccess(mRepository::deleteList())
.subscribeOn(mSchedulerProvider.io())
浏览 0提问于2017-06-10得票数 1
回答已采纳
我对这里一无所知。我正在尝试使用安卓的RxJava库，但是遇到了错误。逻辑是处理按钮上的点击事件，然后将其映射为从EditText获取值，然后将其flatmap到Single<String>，后者通过网络解析值。我尝试使用Schedulers.io()在IO线程上运行flatmap，但遇到错误： E/MainActivity: Login error
java.lang.IllegalStateException: Expected to be called on the main thread but was RxCachedThreadScheduler-1
浏览 60提问于2019-09-21得票数 1
回答已采纳
有一个例外，它反复出现在我的应用程序的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
1回答
Rx中的错误处理
、、
我正在尝试处理Rx网络中的错误，但是不能这样做可以提供一些帮助。
getCompositeDisposable().add(getManager().callApi(request)
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.ui())
.subscribe(apiResponse -> Log.d(TAG,"success"),
throwable -> Log.e(TAG,throwable.getMessage)));
浏览 3提问于2018-06-01得票数 0
我正在尝试使用RxAndroid和RxJava，但是我有点困惑，下面提到的库我应该使用哪一个呢？在一些教程中，他们使用了以下类，这些类在
compile 'io.reactivex:rxandroid:1.2.1'
compile 'io.reactivex:rxjava:1.1.9'
.subscribe(new Subscriber<String>)
一些教程(例如，它们使用下面的库中提供的类)
compile 'io.reactivex.rxjava2:rxjava:2.0.1'
compile 'io.rea
浏览 3提问于2017-09-23得票数 0
1回答
如下面的代码所示，由于转换是不正确的，所以在下面的行中出现了一个错误
.subscribe((Consumer<? super List<String>>)getAnimalsObserver());
请告诉我如何解决这个问题。
备注：
I am using the folloing rx versions
compile 'io.reactivex.rxjava2:rxandroid:2.0.2'
compile 'io.reactivex.rxjava2:rxjava:2.0.5'
码
import io.reactivex.Obse
浏览 1提问于2018-07-17得票数 1
回答已采纳
尝试从Spring Boot ApplicationRunner调用RxJava2时，我得到了一个非常隐秘的异常：
java.lang.IllegalStateException: Failed to execute ApplicationRunner
at org.springframework.boot.SpringApplication.callRunner(SpringApplication.java:770)
at org.springframework.boot.SpringApplication.callRunners(SpringApplication.java
浏览 12提问于2017-06-15得票数 0
回答已采纳
2回答
我正在调用一个API，它会抛出404状态代码，并且由于该应用程序崩溃。下面提到了代码片段：
fun loadAndSavedata(
type: Type,
bookmark: String? = null,
): Single<MetaData> {
return loadFilesByType(type, bookmark)
.map { response ->
if (!response.isSuccessfulAndHasBody()) {
//This line gets
浏览 20提问于2022-02-15得票数 0
如建议的那样，我安装时使用
npm install @reactivex/rxjs@5.0.0-beta.11
我可以以这种方式导入几乎所有的东西：
import { Observable, Subscriber } from '@reactivex/rxjs';
但不是WebSocketSubject。我试过：
import { WebSocketSubject } from '@reactivex/rxjs';
import { WebSocketSubject } from '@reactivex/rxjs/observable/dom';
浏览 2提问于2016-08-23得票数 1
回答已采纳
我正在用Retrofit2+RxJava+RxAndroid打网络电话。
我也尝试过不同的Schedulers，io()和newThread().我知道使用newThread()的后果，但应用仍然是关闭OOM的原因。
设想情况：
筛选列表(过滤后的65项)
从URL下载gzip
写入字节并存储在领域中
以上网络呼叫发生65次。
代码：
/*form version download method*/
public void startFormDownload(List<Form> form, ApiClient apiClient) {
Observab
浏览 2提问于2018-01-23得票数 1
回答已采纳
我是RxJava2的新手，不确定是否正确使用它。
我有几个InputStreams正在从TCP流中读取数据，并且正在将数据读取到byte[]中。然后，我获取byte[]并为每个InputStream创建一个Flowable，然后将各个Flowable合并为一个。
我希望能够关闭1个InputStream，但仍然可以让合并的Flowable继续从未关闭的InputStream读取。
目前，我让它正确地从2 InputStreams读取，但当我调用close时，它导致了一个异常，java.net.SocketException: Socket closed被抛出。
我的问题是，我如何正确地关闭In
浏览 4提问于2017-07-12得票数 1
回答已采纳
1回答
我连接超时了： 2019-09-01 18:20:52.732 9389-9389/com.example.homecinema E/AndroidRuntime: FATAL EXCEPTION: main
Process: com.example.homecinema, PID: 9389
io.reactivex.exceptions.OnErrorNotImplementedException: connect timed out
at io.reactivex.internal.functions.Functions$OnErrorMissingConsumer.accep
浏览 21提问于2019-09-01得票数 1
回答已采纳
我需要管理多个文件上传到我的Micronaut控制器(具有相同部件名称的多个部件)。 我尝试了以下方法： @Post(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA)
HttpResponse upload(Publisher<CompletedFileUpload> files) 还有这一条： HttpResponse upload(Publisher<Publisher<PartData>> files) 我使用curl测试API，如下所示： curl -X POS
浏览 52提问于2019-06-05得票数 2
1回答
在deno中导入esm2015
、、、、
从UMD模块命名导入(不认为UMD在浏览器中工作，Deno似乎类似于浏览器？)：
import { range } from "https://unpkg.com/@reactivex/rxjs@6.6.3/dist/global/rxjs.umd.js";
import { operators } from "https://unpkg.com/@reactivex/rxjs@6.6.3/dist/global/rxjs.umd.js";
结果：
error: Uncaught SyntaxError: The requested module 'h
浏览 6提问于2021-02-12得票数 1
我在Crashlytics上得到了很多与我为FirebaseRemoteConfig创建的rx-wrapper相关的NPE崩溃。
我的代码：
public Completable fetch() {
remoteConfig.activateFetched();
return Completable.create(e ->
remoteConfig.fetch(cacheExpiration).addOnCompleteListener(
task -> {
浏览 0提问于2017-08-16得票数 0
1回答
我用ACRA发送Android应用程序的崩溃报告，一切都很好。除了堆栈跟踪是巨大的。例如，报告可以包含大约30000个字符，如下所示：
{
"REPORT_ID": "bb7cef15-ffc0-4e58-ada2-0472a5c02939",
"APP_VERSION_CODE": 1,
"APP_VERSION_NAME": 1.8,
"PHONE_MODEL": "Nexus 5",
"ANDROID_VERSION": "6.0.1",
浏览 1提问于2017-10-24得票数 1
回答已采纳
我正在尝试修复我发布到play商店的应用程序中crashlytics报告的一些错误 我查过日志了，但我不知道该怎么处理... io.reactivex.exceptions.UndeliverableException:
at io.reactivex.plugins.RxJavaPlugins.onError (RxJavaPlugins.java:367)
at io.reactivex.internal.operators.single.SingleFromCallable.subscribeActual (SingleFromCallable.java:50)
at i
浏览 21提问于2019-05-09得票数 0
回答已采纳
我尝试将下面的AsyncTask代码转换为Rxjava2，但显然Rxjava2不处理空值，因此我的应用程序崩溃。下面是我的AsyncTask代码：
new AsyncTask<Void, Void, Void>() {
@Override
protected Void doInBackground(Void... params) {
Set<Map.Entry<String, Participant>> entries = pool.entrySet();
浏览 24提问于2017-12-12得票数 1
回答已采纳
这个异常最终没有被处理，在Crashlytics中被报告为非致命的，因此从雷达上掉下来的用户看到了一个空白页，这是不可取的，因为崩溃会更好，因为失败是首选的。
理想情况下，我希望onError使用者成为触发器，这是我处理错误的地方，例如显示每个流的错误UI
然而，
fun main() {
Single.just(listOf("efaewf"))
.subscribe({
println("result is ${it[1]}")
}, {
浏览 5提问于2021-04-07得票数 1
回答已采纳
在我的angular2组件中，
import * as Rx from '@reactivex/rxjs';
Visual抱怨“找不到模块@reactivex/rxjs”
我看到@reactivex\rxjs是在node_modules下angular2下安装的。下面是文件夹结构。
node_modules\angular2\node_modules\@reactivex\rxjs
如何修复，以便在组件中使用Rx？
更新：
一个类似的来自吉特布。
浏览 2提问于2015-11-24得票数 3
下面有一个简单的代码
compositeDisposable.add(Observable.create<Int> { Thread.sleep(1000) }
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({}, {Log.d("Track", it.localizedMessage)}, {}))
Handler().postDelayed({compositeDisposabl
浏览 1提问于2019-08-25得票数 0
回答已采纳
1回答
正如标题所示，我正在尝试使用Docker为基于Kotlin的Micronaut应用程序构建本机映像。
我已经向我的build.gradle文件添加了以下依赖项。
compileOnly 'org.graalvm.nativeimage:svm'
annotationProcessor 'io.micronaut:micronaut-graal'
我的Dockerfile如下所示。
FROM oracle/graalvm-ce:20.1.0-java11 as graalvm
RUN gu install native-image
WORKDIR /src
CO
浏览 4提问于2020-05-30得票数 1
回答已采纳
尝试为使用observeOn(AndroidSchedulers.mainThread())的演示者运行JUnit测试时遇到RuntimeException。
由于它们是纯JUnit测试，而不是Android工具测试，它们不能访问Android依赖项，导致我在执行测试时遇到以下错误：
java.lang.ExceptionInInitializerError
at io.reactivex.android.schedulers.AndroidSchedulers$1.call(AndroidSchedulers.java:35)
at io.reactivex.android.
浏览 581提问于2017-04-12得票数 68
回答已采纳
我用的是RxJava和AndroidStudio的最新预览版。我的项目启用了java1.8支持，如下所示：
compileOptions {
targetCompatibility 1.8
sourceCompatibility 1.8
}
但是，在编译和运行代码时，即使我有onError处理程序，请求一发出，我也会得到这个错误：
java.lang.NoClassDefFoundError: Failed resolution of: Lcom/google/devtools/build/android/desugar/runtime/ThrowableExtension;
浏览 3提问于2017-05-22得票数 13
回答已采纳
1回答
我是反应式编程的新手，目前正在学习kotlin。我正在尝试使用okhttp客户端发出API请求，但我想尝试rxjava，而不是使用asynctask。
fun network():Observable<String>{
val exe = Observable.create<String> { emitter->
emitter.onNext("https://pokeapi.co/api/v2/pokemon/500")
}
return exe.onErrorReturn{
it.toS
浏览 4提问于2019-12-04得票数 0
我刚开始使用RxAndroid和RxJava。我正在使用RxJava + Retrofit2发出GET请求。我正在使用下面的代码执行大约1500个GET请求，并出现内存不足错误。然而，同样的代码这次只进行了改造，没有RxAndroid，它可以工作。所以我的结论是我在RxAndroid中做错了什么。你能帮我补上我错过的东西吗？
代码示例：
Subject<Story> mStoryEmitter = PublishSubject.create();
private void getStory(int storyID) {
HNApi.Factory.getInstance(
浏览 2提问于2017-08-08得票数 10
在请求过程中调用.dispose()会导致NPE。有没有办法解决这个问题？ 错误消息 java.lang.NullPointerException: The callable returned a null value
W/System.err: at io.reactivex.internal.functions.ObjectHelper.requireNonNull(ObjectHelper.java:39)
at io.reactivex.internal.operators.single.SingleFromCallable.subscribeActu
浏览 38提问于2019-03-18得票数 0
回答已采纳
我和一起工作。在所有设备上，代码都可以正常工作，但在Nexus 5手机上，日志中有一个例外。
我的代码：
override fun fromAddress(address: Address): Observable<Geolocation> {
val location = geocoder.getFromLocationName("${address.street} ${address.number}, ${address.postcode}, ${address.city}", LOCATIONS_MAX_RESULTS).first()
ret
浏览 4提问于2017-10-30得票数 10
1回答
我开始使用RXAndroid，我已经发布了我的第一个测试版，我得到了一个我没想到的例外。我确信，这是因为我对onError方法的工作原理缺乏了解。
我的代码是这样的：
disposables.add(Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
浏览 3提问于2017-06-07得票数 4
回答已采纳
在Ammonite中，我执行以下代码...试着做两个可流动的orderedMerge，
import $ivy.{
`io.circe::circe-generic:0.13.0` ,
`io.circe::circe-parser:0.13.0` ,
`io.circe::circe-optics:0.13.0` ,
`com.softwaremill.sttp::core:1.7.2` ,
`org.s
浏览 10提问于2020-05-21得票数 1
回答已采纳
我正在尝试使用micronaut (1.2.0)的多个数据库连接，没有对我有效的注入方法，这是我的配置： application.yml datasources:
default:
url: ${JDBC_URL:`jdbc:mysql://localhost/cossine?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC`}
username: ${JDBC_USER:******}
pass
浏览 100提问于2019-08-27得票数 1
回答已采纳
在使用UndeliverableException时获取completable
public Completable createBucketWithStorageClassAndLocation() {
return Completable.complete()
.doFinally(() -> {
Bucket bucket =
storage.create(
BucketInfo.newBuilder(googleU
浏览 1提问于2021-03-11得票数 12
回答已采纳
我有一个PublishSubject：
subjectA = PublishSubject.create()
然后，妓女的操作类似于：
subjectA
.flatMap {
//..
}
.flatMapUntil({ it }) {
//..
}
.observeOn(AndroidSchedulers.mainThread())
.filter { it.isFilter }
.doOnNext {
//..
}
.doOnError { e->
浏览 9提问于2022-03-01得票数 1
回答已采纳
minifyEnabled=false构建成功，minifyEnabled=false构建失败
构建debugApk成功，但构建releaseApk失败
请帮帮我，我找不到问题所在
FORCE inlining on non-inlinable: void io.reactivex.rxjava3.disposables.RunnableDisposable.constructor$io$reactivex$rxjava3$disposables$ReferenceDisposable(java.lang.Object)
Stack trace:
com.android.tools.r8.er
浏览 21提问于2020-09-18得票数 2
我使用的是Android Studio 4.1.3和它的各种捆绑工具(AGP 4.1.3，Gradle 6.5，Android SDK构建工具31-rc2，平台工具31.0.1，SDK工具26.1.1)。我使用的是默认的R8工具。 我混淆了发布版本，如下所示： release {
// Enables code shrinking, obfuscation, and optimization for only
// your project's release build type.
minifyEnabled true
// Enables resourc
浏览 116提问于2021-04-08得票数 1
回答已采纳
在编写RxJava POC程序时，我面临一个运行时异常，如下所示。
多亏了@akarnokd (在这个中)，我能够拦截doOnError()回调中存在于可流对象上的错误。
问题是，即使我拦截了它的过程，我也不能真正“吞下”(忽略)它并有效地关闭从可观察到的流到我的观察者。
下面是代码后面的异常：
由于在io.reactivex.exceptions.OnErrorNotImplementedException：()方法调用中缺少onError处理程序，所以没有处理异常。进一步阅读： / io.grpc.StatusRuntimeException: closed : RST_STREAM关闭流
浏览 8提问于2022-03-17得票数 -2
6回答
在构建角应用程序时，我得到了许多这些错误，下面是第一个错误
ERROR in ./~/@reactivex/rxjs/dist/cjs/Rx.js
Module not found: Error: Can't resolve './add/operator/filter' in
'...\node_modules\@reactivex\rxjs\dist\cjs'
@ ./~/@reactivex/rxjs/dist/cjs/Rx.js 70:0-32
@ ./~/@reactivex/rxjs/index.js
@ ./~/ri-api-cli
浏览 8提问于2017-05-08得票数 15
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
