Skip to content

Commit 316c2ee

Browse files
hanggatheangrydev
andauthored
Update core-kotlin-modules/core-kotlin-collections-6/src/test/kotlin/com/baeldung/parallelOperationsCollections/ParallelOperationCollectionsUnitTest.kt
Yes, I agree on this one Co-authored-by: Liam Williams <[email protected]>
1 parent 0f547e8 commit 316c2ee

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

core-kotlin-modules/core-kotlin-collections-6/src/test/kotlin/com/baeldung/parallelOperationsCollections/ParallelOperationCollectionsUnitTest.kt

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -104,9 +104,10 @@ class ParallelOperationCollectionsUnitTest {
104104

105105
val observable = Observable.fromIterable(people)
106106
.flatMap(
107-
{ Observable.just(it)
108-
.subscribeOn(Schedulers.computation())
109-
.doOnNext { person -> person.setAdult()}
107+
{
108+
Observable.just(it)
109+
.subscribeOn(Schedulers.computation())
110+
.doOnNext { person -> person.setAdult() }
110111
},
111112
people.size // Uses maxConcurrency for the number of elements
112113
)
@@ -127,9 +128,10 @@ class ParallelOperationCollectionsUnitTest {
127128

128129
val observable = people.toObservable()
129130
.flatMap(
130-
{ Observable.just(it)
131-
.subscribeOn(Schedulers.computation())
132-
.doOnNext { person -> person.setAdult() }
131+
{
132+
Observable.just(it)
133+
.subscribeOn(Schedulers.computation())
134+
.doOnNext { person -> person.setAdult() }
133135
},
134136
people.size // Uses maxConcurrency for the number of elements
135137
).filter { it.age > 15 }

0 commit comments

Comments
 (0)