Skip to content

Commit

Permalink
Tweaks
Browse files Browse the repository at this point in the history
  • Loading branch information
Stephan202 committed Apr 7, 2023
1 parent b68f617 commit 28de12f
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1170,7 +1170,7 @@ Flux<T> after(Flux<T> flux, Predicate<? super T> predicate, Comparator<? super T
}

/**
* Prefer {@link Flux#collect(Collector)} with {@link ImmutableSet#toImmutableSet()} over
* Prefer {@link Flux#collect(Collector)} with {@link ImmutableSet#toImmutableSet()} over more
* contrived alternatives.
*/
static final class FluxCollectToImmutableSet<T> {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -378,7 +378,7 @@ Flux<Integer> testFluxFilterSortWithComparator() {
}

Mono<ImmutableSet<Integer>> testFluxCollectToImmutableSet() {
return Flux.just(1, 2).collect(toImmutableList()).map(ImmutableSet::copyOf);
return Flux.just(1).collect(toImmutableList()).map(ImmutableSet::copyOf);
}

ImmutableSet<Context> testContextEmpty() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,7 @@ Flux<Integer> testFluxFilterSortWithComparator() {
}

Mono<ImmutableSet<Integer>> testFluxCollectToImmutableSet() {
return Flux.just(1, 2).collect(toImmutableSet());
return Flux.just(1).collect(toImmutableSet());
}

ImmutableSet<Context> testContextEmpty() {
Expand Down

0 comments on commit 28de12f

Please sign in to comment.