My test code:
package me.piomar.dataflow;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import hu.akarnokd.rxjava3.debug.RxJavaAssemblyTracking;
import io.reactivex.rxjava3.core.Flowable;
import io.reactivex.rxjava3.schedulers.Schedulers;
public class RxErrorApp {
private static final Logger LOGGER = LoggerFactory.getLogger(RxErrorApp.class);
public static void main(String[] args) {
LOGGER.info("App start");
RxJavaAssemblyTracking.enable();
List<String> list = Flowable.just("a", "b", "c")
.observeOn(Schedulers.computation())
.map(RxErrorApp::bang)
.toList()
.blockingGet();
LOGGER.info("Result: {}", list);
}
private static String bang(String input) {
throw new IllegalStateException("bang");
}
}The result in console:
Exception in thread "main" java.lang.IllegalStateException: bang
at me.piomar.dataflow.RxErrorApp.bang(RxErrorApp.java:29)
at io.reactivex.rxjava3.internal.operators.flowable.FlowableMap$MapSubscriber.onNext(FlowableMap.java:64)
at hu.akarnokd.rxjava3.debug.FlowableOnAssembly$OnAssemblySubscriber.onNext(FlowableOnAssembly.java:61)
at io.reactivex.rxjava3.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.runSync(FlowableObserveOn.java:337)
at io.reactivex.rxjava3.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.run(FlowableObserveOn.java:174)
at io.reactivex.rxjava3.internal.schedulers.ScheduledRunnable.run(ScheduledRunnable.java:65)
at io.reactivex.rxjava3.internal.schedulers.ScheduledRunnable.call(ScheduledRunnable.java:56)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: hu.akarnokd.rxjava3.debug.RxJavaAssemblyException
Caused by: hu.akarnokd.rxjava3.debug.RxJavaAssemblyException
As it can be seen, there is no stack trace printed inside RxJavaAssemblyException. I'm using OpenJDK11, compiling to Java 8 (tested on JDK8 with same result). During debug, it can be seen that there is String RxJavaAssemblyException.stacktrace field which has been filled properly but seems it's not used anywhere.
Maven dependencies:
<dependency>
<groupId>com.github.akarnokd</groupId>
<artifactId>rxjava3-extensions</artifactId>
<version>3.0.0</version>
</dependency>
<dependency>
<groupId>io.reactivex.rxjava3</groupId>
<artifactId>rxjava</artifactId>
<version>3.0.5</version>
</dependency>
My test code:
The result in console:
As it can be seen, there is no stack trace printed inside
RxJavaAssemblyException. I'm using OpenJDK11, compiling to Java 8 (tested on JDK8 with same result). During debug, it can be seen that there isString RxJavaAssemblyException.stacktracefield which has been filled properly but seems it's not used anywhere.Maven dependencies: