Skip to content

Commit b47783e

Browse files
committed
Fix trailing spaces.
1 parent 51de021 commit b47783e

File tree

4 files changed

+7
-6
lines changed

4 files changed

+7
-6
lines changed

src/main/java/io/reactivex/rxjava3/internal/fuseable/FuseToFlowable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
* the operator goes from Flowable to some other reactive type and then the sequence calls
2222
* for toFlowable again:
2323
* <pre>
24-
* {@code
24+
* {@code
2525
* Single<Integer> single = Flowable.range(1, 10).reduce((a, b) -> a + b);
2626
* Flowable<Integer> flowable = single.toFlowable();
2727
* }

src/main/java/io/reactivex/rxjava3/internal/fuseable/FuseToMaybe.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
* the operator goes from Maybe to some other reactive type and then the sequence calls
2222
* for toMaybe again:
2323
* <pre>
24-
* {@code
24+
* {@code
2525
* Single<Integer> single = Maybe.just(1).isEmpty();
2626
* Maybe<Integer> maybe = single.toMaybe();
2727
* }

src/main/java/io/reactivex/rxjava3/internal/schedulers/SchedulerWhen.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@
5353
* thread pool:
5454
*
5555
* <pre>
56-
* {@code
56+
* {@code
5757
* Scheduler limitScheduler = Schedulers.computation().when(workers -> {
5858
* // use merge max concurrent to limit the number of concurrent
5959
* // callbacks two at a time
@@ -73,7 +73,7 @@
7373
* to the second.
7474
*
7575
* <pre>
76-
* {@code
76+
* {@code
7777
* Scheduler limitScheduler = Schedulers.computation().when(workers -> {
7878
* // use merge max concurrent to limit the number of concurrent
7979
* // Observables two at a time
@@ -88,7 +88,7 @@
8888
* algorithm).
8989
*
9090
* <pre>
91-
* {@code
91+
* {@code
9292
* Scheduler slowScheduler = Schedulers.computation().when(workers -> {
9393
* // use concatenate to make each worker happen one at a time.
9494
* return Completable.concat(workers.map(actions -> {

src/test/java/io/reactivex/rxjava3/observers/SerializedObserverTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1042,7 +1042,8 @@ public void run() {
10421042
}
10431043
};
10441044

1045-
TestHelper.race(r1, r2);
1045+
TestHelper.race(r1, r2);
1046+
10461047
to.awaitDone(5, TimeUnit.SECONDS)
10471048
.assertError(ex)
10481049
.assertNotComplete();

0 commit comments

Comments
 (0)