Home / ReactiveX / RxJava
Repository Analysis

ReactiveX/RxJava

RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.

1.3 Likely human-written View on GitHub
1.3
Adjusted Score
1.3
Raw Score
100%
Time Factor
2026-05-25
Last Push
48,246
Stars
Java
Language
473,466
Lines of Code
1989
Files
98
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 51HIGH 0MEDIUM 9LOW 38

Pattern Findings

98 matches across 7 categories. Click a row to expand file-level details.

Hallucination Indicators51 hits · 528 pts
SeverityFileLineSnippet
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java147 return io.reactivex.rxjava4.core.Observable.just(1);
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java154 return io.reactivex.rxjava4.core.Observable.range(1, 10);
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java161 return io.reactivex.rxjava4.core.Observable.empty();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java168 return io.reactivex.rxjava4.core.Observable.fromCallable(new Callable<Object>() {
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java194 return io.reactivex.rxjava4.core.Observable.just(1).subscribeWith(new MyRx2Observer());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java201 return io.reactivex.rxjava4.core.Observable.range(1, 10).subscribeWith(new MyRx2Observer());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java208 return io.reactivex.rxjava4.core.Observable.range(1, 10).map(new Function<Integer, Object>() {
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java237 return io.reactivex.rxjava4.core.Observable.range(1, 10)
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java238 .subscribeOn(io.reactivex.rxjava4.schedulers.Schedulers.computation())
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java246 return io.reactivex.rxjava4.core.Observable.range(1, 10)
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java247 .observeOn(io.reactivex.rxjava4.schedulers.Schedulers.computation())
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java255 return io.reactivex.rxjava4.core.Observable.range(1, 10)
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java256 .subscribeOn(io.reactivex.rxjava4.schedulers.Schedulers.computation())
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java257 .observeOn(io.reactivex.rxjava4.schedulers.Schedulers.computation())
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java265 return io.reactivex.rxjava4.subjects.AsyncSubject.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java272 return io.reactivex.rxjava4.subjects.PublishSubject.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java279 return io.reactivex.rxjava4.subjects.ReplaySubject.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java286 return io.reactivex.rxjava4.subjects.BehaviorSubject.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java293 return io.reactivex.rxjava4.subjects.UnicastSubject.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java300 return io.reactivex.rxjava4.subjects.AsyncSubject.create().subscribeWith(new MyRx2Observer());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java307 return io.reactivex.rxjava4.subjects.PublishSubject.create().subscribeWith(new MyRx2Observer());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java314 return io.reactivex.rxjava4.subjects.ReplaySubject.create().subscribeWith(new MyRx2Observer());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java321 return io.reactivex.rxjava4.subjects.BehaviorSubject.create().subscribeWith(new MyRx2Observer());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java328 return io.reactivex.rxjava4.subjects.UnicastSubject.create().subscribeWith(new MyRx2Observer());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java337 return io.reactivex.rxjava4.core.Flowable.just(1);
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java344 return io.reactivex.rxjava4.core.Flowable.range(1, 10);
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java351 return io.reactivex.rxjava4.core.Flowable.empty();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java358 return io.reactivex.rxjava4.core.Flowable.empty();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java365 return io.reactivex.rxjava4.core.Flowable.fromCallable(new Callable<Object>() {
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java391 return io.reactivex.rxjava4.core.Flowable.just(1).subscribeWith(new MyRx2Subscriber());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java398 return io.reactivex.rxjava4.core.Flowable.range(1, 10).subscribeWith(new MyRx2Subscriber());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java405 return io.reactivex.rxjava4.core.Flowable.range(1, 10).map(new Function<Integer, Object>() {
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java434 return io.reactivex.rxjava4.core.Flowable.range(1, 10)
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java435 .subscribeOn(io.reactivex.rxjava4.schedulers.Schedulers.computation())
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java443 return io.reactivex.rxjava4.core.Flowable.range(1, 10)
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java444 .observeOn(io.reactivex.rxjava4.schedulers.Schedulers.computation())
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java452 return io.reactivex.rxjava4.core.Flowable.range(1, 10)
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java453 .subscribeOn(io.reactivex.rxjava4.schedulers.Schedulers.computation())
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java454 .observeOn(io.reactivex.rxjava4.schedulers.Schedulers.computation())
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java462 return io.reactivex.rxjava4.processors.AsyncProcessor.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java469 return io.reactivex.rxjava4.processors.PublishProcessor.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java476 return io.reactivex.rxjava4.processors.ReplayProcessor.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java483 return io.reactivex.rxjava4.processors.BehaviorProcessor.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java490 return io.reactivex.rxjava4.processors.UnicastProcessor.create();
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java497 return io.reactivex.rxjava4.processors.AsyncProcessor.create().subscribeWith(new MyRx2Subscriber());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java504 return io.reactivex.rxjava4.processors.PublishProcessor.create().subscribeWith(new MyRx2Subscriber());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java511 return io.reactivex.rxjava4.processors.ReplayProcessor.create().subscribeWith(new MyRx2Subscriber());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java518 return io.reactivex.rxjava4.processors.BehaviorProcessor.create().subscribeWith(new MyRx2Subscriber());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java525 return io.reactivex.rxjava4.processors.UnicastProcessor.create().subscribeWith(new MyRx2Subscriber());
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java220 return io.reactivex.rxjava4.core.Observable.range(1, 10).map(new Function<Integer, Object>() {
CRITICALsrc/jmh/java/io/reactivex/rxjava4/core/MemoryPerf.java417 return io.reactivex.rxjava4.core.Flowable.range(1, 10).map(new Function<Integer, Object>() {
Decorative Section Separators9 hits · 32 pts
SeverityFileLineSnippet
MEDIUMpush_javadoc.sh2# ----------------------------------------------------------
MEDIUMpush_javadoc.sh4# ----------------------------------------------------------
MEDIUMpush_javadoc.sh9# =======================================================================
MEDIUMpush_javadoc.sh57 # ----------------
MEDIUM.github/workflows/gradle_snapshot.yml18 # ------------------------------------------------------------------------------
MEDIUM.github/workflows/gradle_snapshot.yml87 # ------------------------------------------------------------------------------
MEDIUM.github/workflows/gradle_snapshot.yml93 # ------------------------------------------------------------------------------
MEDIUM.github/workflows/gradle_release.yml76 # ------------------------------------------------------------------------------
MEDIUM.github/workflows/gradle_release.yml85 # ------------------------------------------------------------------------------
Over-Commented Block21 hits · 21 pts
SeverityFileLineSnippet
LOWpush_javadoc.sh41# get the gh-pages
LOWpush_javadoc.sh61
LOWdocs/Transforming-Observables.md201
LOWdocs/Transforming-Observables.md401 })
LOWdocs/Error-Handling-Operators.md81 .subscribe(
LOWdocs/Error-Handling-Operators.md281// onNext: 1
LOWdocs/Combining-Observables.md101#### combineLatest Example
LOWdocs/Combining-Observables.md141// prints:
LOW…perators/flowable/FlowableTimeoutWithSelectorTest.java261 // Thread 1 Thread 2
LOW…/internal/operators/flowable/NotificationLiteTest.java101 assertFalse(NotificationLite.isError(o));
LOW…/internal/operators/flowable/NotificationLiteTest.java121// assertFalse(NotificationLite.isNext(null));
LOW…tors/observable/ObservableTimeoutWithSelectorTest.java261 // Thread 1 Thread 2
LOW…4/internal/operators/observable/ObservableMapTest.java261// @Override
LOW…4/internal/operators/observable/ObservableMapTest.java281//
LOW…4/internal/operators/observable/ObservableMapTest.java301// Observable.unsafeCreate(creator).flatMap(manyMapper).map(mapper).subscribe(onNext);
LOW…4/internal/operators/observable/ObservableMapTest.java321// return Observable.just(s + "1", s + "2");
LOW…ernal/operators/observable/ObservableDoOnEachTest.java181// @Override
LOW…va/io/reactivex/rxjava4/observable/ObservableTest.java1021// @Test // cf. https://github.com/ReactiveX/RxJava/issues/2599
LOW…/reactivex/rxjava4/internal/util/QueueDrainHelper.java301 static <T> boolean postCompleteDrain(long n,
LOW…tivex/rxjava4/internal/schedulers/RxThreadFactory.java61// }
LOW…ava/io/reactivex/rxjava4/core/OperatorFlatMapPerf.java81 // Observable.range(1, 2).flatMap(new Func1<Integer, Observable<Integer>>() {
Verbosity Indicators12 hits · 18 pts
SeverityFileLineSnippet
LOWsrc/main/java/io/reactivex/rxjava4/core/Single.java3767 * // Step 1: Create the consumer type that will be returned by the SingleOperator.apply():
LOWsrc/main/java/io/reactivex/rxjava4/core/Single.java3836 * // Step 2: Create a class that implements the SingleOperator interface and
LOWsrc/main/java/io/reactivex/rxjava4/core/Single.java3848 * // Step 3: Apply the custom operator via lift() in a flow by creating an instance of it
LOWsrc/main/java/io/reactivex/rxjava4/core/Observable.java10289 * // Step 1: Create the consumer type that will be returned by the ObservableOperator.apply():
LOWsrc/main/java/io/reactivex/rxjava4/core/Observable.java10364 * // Step 2: Create a class that implements the ObservableOperator interface and
LOWsrc/main/java/io/reactivex/rxjava4/core/Observable.java10376 * // Step 3: Apply the custom operator via lift() in a flow by creating an instance of it
LOWsrc/main/java/io/reactivex/rxjava4/core/Maybe.java4197 * // Step 1: Create the consumer type that will be returned by the MaybeOperator.apply():
LOWsrc/main/java/io/reactivex/rxjava4/core/Maybe.java4272 * // Step 2: Create a class that implements the MaybeOperator interface and
LOWsrc/main/java/io/reactivex/rxjava4/core/Maybe.java4284 * // Step 3: Apply the custom operator via lift() in a flow by creating an instance of it
LOW…c/main/java/io/reactivex/rxjava4/core/Completable.java2060 * // Step 1: Create the consumer type that will be returned by the CompletableOperator.apply():
LOW…c/main/java/io/reactivex/rxjava4/core/Completable.java2122 * // Step 2: Create a class that implements the CompletableOperator interface and
LOW…c/main/java/io/reactivex/rxjava4/core/Completable.java2134 * // Step 3: Apply the custom operator via lift() in a flow by creating an instance of it
Slop Phrases3 hits · 4 pts
SeverityFileLineSnippet
LOW…/java/io/reactivex/rxjava4/testsupport/TestHelper.java3928 * Don't forget to {@link ExecutorService#submit(Callable)} your work!
LOW…/java/io/reactivex/rxjava4/testsupport/TestHelper.java4035 * Don't forget to {@link ExecutorService#submit(Callable)} your work!
LOW…/java/io/reactivex/rxjava4/testsupport/TestHelper.java4048 * Don't forget to {@link ExecutorService#submit(Callable)} your work!
Excessive Try-Catch Wrapping1 hit · 1 pts
SeverityFileLineSnippet
LOW.github/workflows/compute-entropy.py45 except Exception:
Unused Imports1 hit · 1 pts
SeverityFileLineSnippet
LOW.github/workflows/compute-entropy.py2