Skip to content

Commit 7c59877

Browse files
akarnokdakarnokd
committed
Lambda unused parameter cleanup 5/5
1 parent bbd6e5f commit 7c59877

20 files changed

Lines changed: 90 additions & 90 deletions

‎src/test/java/io/reactivex/rxjava4/internal/jdk8/ParallelFlatMapStreamTest.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ public class ParallelFlatMapStreamTest extends RxJavaTest {
2525
@Test
2626
public void subscriberCount() {
2727
ParallelFlowableTest.checkSubscriberCount(Flowable.range(1, 5).parallel()
28-
.flatMapStream(v -> Stream.of(1, 2, 3)));
28+
.flatMapStream(_ -> Stream.of(1, 2, 3)));
2929
}
3030

3131
@Test
@@ -48,7 +48,7 @@ public void none() {
4848
for (int i = 1; i < 32; i++) {
4949
Flowable.range(1, 1000)
5050
.parallel(i)
51-
.flatMapStream(v -> Stream.of())
51+
.flatMapStream(_ -> Stream.of())
5252
.sequential()
5353
.test()
5454
.withTag("Parallelism: " + i)

‎src/test/java/io/reactivex/rxjava4/internal/jdk8/ParallelMapOptionalTest.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ public void error() {
130130
public void mapCrash() {
131131
Flowable.just(1)
132132
.parallel()
133-
.mapOptional(v -> { throw new TestException(); })
133+
.mapOptional(_ -> { throw new TestException(); })
134134
.sequential()
135135
.test()
136136
.assertFailure(TestException.class);
@@ -140,7 +140,7 @@ public void mapCrash() {
140140
public void mapCrashConditional() {
141141
Flowable.just(1)
142142
.parallel()
143-
.mapOptional(v -> { throw new TestException(); })
143+
.mapOptional(_ -> { throw new TestException(); })
144144
.filter(Functions.alwaysTrue())
145145
.sequential()
146146
.test()
@@ -152,7 +152,7 @@ public void mapCrashConditional2() {
152152
Flowable.just(1)
153153
.parallel()
154154
.runOn(Schedulers.computation())
155-
.mapOptional(v -> { throw new TestException(); })
155+
.mapOptional(_ -> { throw new TestException(); })
156156
.filter(Functions.alwaysTrue())
157157
.sequential()
158158
.test()
@@ -164,7 +164,7 @@ public void mapCrashConditional2() {
164164
public void allNone() {
165165
Flowable.range(1, 1000)
166166
.parallel()
167-
.mapOptional(v -> Optional.empty())
167+
.mapOptional(_ -> Optional.empty())
168168
.sequential()
169169
.test()
170170
.assertResult();
@@ -174,8 +174,8 @@ public void allNone() {
174174
public void allNoneConditional() {
175175
Flowable.range(1, 1000)
176176
.parallel()
177-
.mapOptional(v -> Optional.empty())
178-
.filter(v -> true)
177+
.mapOptional(_ -> Optional.empty())
178+
.filter(_ -> true)
179179
.sequential()
180180
.test()
181181
.assertResult();
@@ -198,7 +198,7 @@ public void mixedConditional() {
198198
Flowable.range(1, 1000)
199199
.parallel()
200200
.mapOptional(v -> v % 2 == 0 ? Optional.of(v) : Optional.empty())
201-
.filter(v -> true)
201+
.filter(_ -> true)
202202
.sequential()
203203
.test()
204204
.assertValueCount(500)
@@ -222,7 +222,7 @@ public void doubleOnSubscribe() {
222222

223223
TestHelper.checkDoubleOnSubscribeParallel(
224224
p -> p.mapOptional(Optional::of)
225-
.filter(v -> true)
225+
.filter(_ -> true)
226226
);
227227
}
228228
}

‎src/test/java/io/reactivex/rxjava4/internal/jdk8/ParallelMapTryOptionalTest.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -301,7 +301,7 @@ public void failureHandlingEnum() {
301301
public void allNone() {
302302
Flowable.range(1, 1000)
303303
.parallel()
304-
.mapOptional(v -> Optional.empty(), ParallelFailureHandling.SKIP)
304+
.mapOptional(_ -> Optional.empty(), ParallelFailureHandling.SKIP)
305305
.sequential()
306306
.test()
307307
.assertResult();
@@ -311,8 +311,8 @@ public void allNone() {
311311
public void allNoneConditional() {
312312
Flowable.range(1, 1000)
313313
.parallel()
314-
.mapOptional(v -> Optional.empty(), ParallelFailureHandling.SKIP)
315-
.filter(v -> true)
314+
.mapOptional(_ -> Optional.empty(), ParallelFailureHandling.SKIP)
315+
.filter(_ -> true)
316316
.sequential()
317317
.test()
318318
.assertResult();
@@ -335,7 +335,7 @@ public void mixedConditional() {
335335
Flowable.range(1, 1000)
336336
.parallel()
337337
.mapOptional(v -> v % 2 == 0 ? Optional.of(v) : Optional.empty(), ParallelFailureHandling.SKIP)
338-
.filter(v -> true)
338+
.filter(_ -> true)
339339
.sequential()
340340
.test()
341341
.assertValueCount(500)
@@ -372,7 +372,7 @@ public void doubleOnSubscribe() {
372372

373373
TestHelper.checkDoubleOnSubscribeParallel(
374374
p -> p.mapOptional(Optional::of, ParallelFailureHandling.ERROR)
375-
.filter(v -> true)
375+
.filter(_ -> true)
376376
);
377377
}
378378
}

‎src/test/java/io/reactivex/rxjava4/internal/jdk8/SingleFlattenStreamAsFlowableTckTest.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,14 +27,14 @@ public class SingleFlattenStreamAsFlowableTckTest extends BaseTck<Integer> {
2727
@Override
2828
public Publisher<Integer> createPublisher(final long elements) {
2929
return
30-
Single.just(1).flattenStreamAsFlowable(v -> IntStream.range(0, (int)elements).boxed())
30+
Single.just(1).flattenStreamAsFlowable(_ -> IntStream.range(0, (int)elements).boxed())
3131
;
3232
}
3333

3434
@Override
3535
public Publisher<Integer> createFailedPublisher() {
3636
Stream<Integer> stream = Stream.of(1);
37-
stream.forEach(v -> { });
38-
return Single.just(1).flattenStreamAsFlowable(v -> stream);
37+
stream.forEach(_ -> { });
38+
return Single.just(1).flattenStreamAsFlowable(_ -> stream);
3939
}
4040
}

‎src/test/java/io/reactivex/rxjava4/internal/jdk8/SingleFlattenStreamAsFlowableTest.java‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -48,23 +48,23 @@ public void successJust() {
4848
@Test
4949
public void successEmpty() {
5050
Single.just(1)
51-
.flattenStreamAsFlowable(v -> Stream.of())
51+
.flattenStreamAsFlowable(_ -> Stream.of())
5252
.test()
5353
.assertResult();
5454
}
5555

5656
@Test
5757
public void successMany() {
5858
Single.just(1)
59-
.flattenStreamAsFlowable(v -> Stream.of(2, 3, 4, 5, 6))
59+
.flattenStreamAsFlowable(_ -> Stream.of(2, 3, 4, 5, 6))
6060
.test()
6161
.assertResult(2, 3, 4, 5, 6);
6262
}
6363

6464
@Test
6565
public void successManyTake() {
6666
Single.just(1)
67-
.flattenStreamAsFlowable(v -> Stream.of(2, 3, 4, 5, 6))
67+
.flattenStreamAsFlowable(_ -> Stream.of(2, 3, 4, 5, 6))
6868
.take(3)
6969
.test()
7070
.assertResult(2, 3, 4);
@@ -86,7 +86,7 @@ public void error() throws Throwable {
8686
@Test
8787
public void mapperCrash() {
8888
Single.just(1)
89-
.flattenStreamAsFlowable(v -> { throw new TestException(); })
89+
.flattenStreamAsFlowable(_ -> { throw new TestException(); })
9090
.test()
9191
.assertFailure(TestException.class);
9292
}
@@ -112,7 +112,7 @@ public void fusedEmpty() {
112112
ts.setInitialFusionMode(QueueFuseable.ANY);
113113

114114
Single.just(1)
115-
.flattenStreamAsFlowable(v -> Stream.<Integer>of())
115+
.flattenStreamAsFlowable(_ -> Stream.<Integer>of())
116116
.subscribe(ts);
117117

118118
ts.assertFuseable()
@@ -165,7 +165,7 @@ public void fusedManyRejected() {
165165
@Test
166166
public void manyBackpressured() {
167167
Single.just(1)
168-
.flattenStreamAsFlowable(v -> IntStream.rangeClosed(1, 5).boxed())
168+
.flattenStreamAsFlowable(_ -> IntStream.rangeClosed(1, 5).boxed())
169169
.test(0L)
170170
.assertEmpty()
171171
.requestMore(2)
@@ -179,7 +179,7 @@ public void manyBackpressured() {
179179
@Test
180180
public void manyBackpressured2() {
181181
Single.just(1)
182-
.flattenStreamAsFlowable(v -> IntStream.rangeClosed(1, 5).boxed())
182+
.flattenStreamAsFlowable(_ -> IntStream.rangeClosed(1, 5).boxed())
183183
.rebatchRequests(1)
184184
.test(0L)
185185
.assertEmpty()
@@ -267,7 +267,7 @@ public void requestOneByOne() {
267267
TestSubscriber<Integer> ts = new TestSubscriber<>();
268268

269269
Single.just(1)
270-
.flattenStreamAsFlowable(v -> Stream.of(1, 2, 3, 4, 5))
270+
.flattenStreamAsFlowable(_ -> Stream.of(1, 2, 3, 4, 5))
271271
.subscribe(new FlowableSubscriber<Integer>() {
272272

273273
Subscription upstream;
@@ -334,7 +334,7 @@ public Integer next() {
334334
});
335335

336336
Single.just(1)
337-
.flattenStreamAsFlowable(v -> stream)
337+
.flattenStreamAsFlowable(_ -> stream)
338338
.test()
339339
.assertFailure(TestException.class, 1);
340340
}
@@ -357,7 +357,7 @@ public Integer next() {
357357
});
358358

359359
Single.just(1)
360-
.flattenStreamAsFlowable(v -> stream)
360+
.flattenStreamAsFlowable(_ -> stream)
361361
.test()
362362
.assertFailure(TestException.class);
363363
}
@@ -388,7 +388,7 @@ public Integer next() {
388388
});
389389

390390
Single.just(1)
391-
.flattenStreamAsFlowable(v -> stream)
391+
.flattenStreamAsFlowable(_ -> stream)
392392
.subscribeWith(ts)
393393
.assertValuesOnly(1);
394394
}
@@ -415,7 +415,7 @@ public Integer next() {
415415
});
416416

417417
Single.just(1)
418-
.flattenStreamAsFlowable(v -> stream)
418+
.flattenStreamAsFlowable(_ -> stream)
419419
.subscribeWith(ts)
420420
.assertEmpty();
421421
}

‎src/test/java/io/reactivex/rxjava4/internal/jdk8/SingleFlattenStreamAsObservableTest.java‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -46,23 +46,23 @@ public void successJust() {
4646
@Test
4747
public void successEmpty() {
4848
Single.just(1)
49-
.flattenStreamAsObservable(v -> Stream.of())
49+
.flattenStreamAsObservable(_ -> Stream.of())
5050
.test()
5151
.assertResult();
5252
}
5353

5454
@Test
5555
public void successMany() {
5656
Single.just(1)
57-
.flattenStreamAsObservable(v -> Stream.of(2, 3, 4, 5, 6))
57+
.flattenStreamAsObservable(_ -> Stream.of(2, 3, 4, 5, 6))
5858
.test()
5959
.assertResult(2, 3, 4, 5, 6);
6060
}
6161

6262
@Test
6363
public void successManyTake() {
6464
Single.just(1)
65-
.flattenStreamAsObservable(v -> Stream.of(2, 3, 4, 5, 6))
65+
.flattenStreamAsObservable(_ -> Stream.of(2, 3, 4, 5, 6))
6666
.take(3)
6767
.test()
6868
.assertResult(2, 3, 4);
@@ -84,7 +84,7 @@ public void error() throws Throwable {
8484
@Test
8585
public void mapperCrash() {
8686
Single.just(1)
87-
.flattenStreamAsObservable(v -> { throw new TestException(); })
87+
.flattenStreamAsObservable(_ -> { throw new TestException(); })
8888
.test()
8989
.assertFailure(TestException.class);
9090
}
@@ -105,7 +105,7 @@ public void fusedEmpty() {
105105
to.setInitialFusionMode(QueueFuseable.ANY);
106106

107107
Single.just(1)
108-
.flattenStreamAsObservable(v -> Stream.<Integer>of())
108+
.flattenStreamAsObservable(_ -> Stream.<Integer>of())
109109
.subscribe(to);
110110

111111
to.assertFuseable()
@@ -314,7 +314,7 @@ public Integer next() {
314314
});
315315

316316
Single.just(1)
317-
.flattenStreamAsObservable(v -> stream)
317+
.flattenStreamAsObservable(_ -> stream)
318318
.test()
319319
.assertFailure(TestException.class, 1);
320320
}
@@ -337,7 +337,7 @@ public Integer next() {
337337
});
338338

339339
Single.just(1)
340-
.flattenStreamAsObservable(v -> stream)
340+
.flattenStreamAsObservable(_ -> stream)
341341
.test()
342342
.assertFailure(TestException.class);
343343
}
@@ -368,7 +368,7 @@ public Integer next() {
368368
});
369369

370370
Single.just(1)
371-
.flattenStreamAsObservable(v -> stream)
371+
.flattenStreamAsObservable(_ -> stream)
372372
.subscribeWith(to)
373373
.assertValuesOnly(1);
374374
}
@@ -395,7 +395,7 @@ public Integer next() {
395395
});
396396

397397
Single.just(1)
398-
.flattenStreamAsObservable(v -> stream)
398+
.flattenStreamAsObservable(_ -> stream)
399399
.subscribeWith(to)
400400
.assertEmpty();
401401
}

‎src/test/java/io/reactivex/rxjava4/internal/jdk8/SingleMapOptionalTest.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public void successSuccess() {
3838
@Test
3939
public void successEmpty() {
4040
Single.just(1)
41-
.mapOptional(v -> Optional.empty())
41+
.mapOptional(_ -> Optional.empty())
4242
.test()
4343
.assertResult();
4444
}
@@ -59,7 +59,7 @@ public void error() throws Throwable {
5959
@Test
6060
public void mapperCrash() {
6161
Single.just(1)
62-
.mapOptional(v -> { throw new TestException(); })
62+
.mapOptional(_ -> { throw new TestException(); })
6363
.test()
6464
.assertFailure(TestException.class);
6565
}

0 commit comments

Comments
 (0)