File tree 3 files changed +6
-9
lines changed
src/test/java/io/reactivex/rxjava3
3 files changed +6
-9
lines changed Original file line number Diff line number Diff line change @@ -634,10 +634,10 @@ public boolean test(Integer t1) {
634
634
}
635
635
636
636
/**
637
- * A synchronous Observable that will emit incrementing integers as requested.
637
+ * A synchronous Flowable that will emit incrementing integers as requested.
638
638
*
639
- * @param counter
640
- * @return
639
+ * @param counter the shared value to be incremented
640
+ * @return the incrementing Flowable instance
641
641
*/
642
642
private static Flowable <Integer > incrementingIntegers (final AtomicInteger counter ) {
643
643
return incrementingIntegers (counter , null );
@@ -689,8 +689,8 @@ public void cancel() {
689
689
/**
690
690
* Incrementing int without backpressure.
691
691
*
692
- * @param counter
693
- * @return
692
+ * @param counter the shared value to increment
693
+ * @return the Flowable doing the increments
694
694
*/
695
695
private static Flowable <Integer > firehose (final AtomicInteger counter ) {
696
696
return Flowable .unsafeCreate (new Publisher <Integer >() {
Original file line number Diff line number Diff line change @@ -466,7 +466,7 @@ public void subscribe(Subscriber<? super String> subscriber) {
466
466
/**
467
467
* Used to determine if onNext is being invoked concurrently.
468
468
*
469
- * @param <T>
469
+ * @param <T> the element type
470
470
*/
471
471
private static class ConcurrentObserverValidator <T > extends DefaultSubscriber <T > {
472
472
Original file line number Diff line number Diff line change @@ -28,9 +28,6 @@ private SchedulerTestHelper() {
28
28
/**
29
29
* Verifies that the given Scheduler does not deliver handled errors to its executing Thread's
30
30
* {@link java.lang.Thread.UncaughtExceptionHandler}.
31
- * <p>
32
- * This is a companion test to {@link #testUnhandledErrorIsDeliveredToThreadHandler}, and is needed only for the
33
- * same Schedulers.
34
31
*/
35
32
static void handledErrorIsNotDeliveredToThreadHandler (Scheduler scheduler ) throws InterruptedException {
36
33
Thread .UncaughtExceptionHandler originalHandler = Thread .getDefaultUncaughtExceptionHandler ();
You can’t perform that action at this time.
0 commit comments