Skip to content

Commit b4ba2d5

Browse files
committed
change ternary return in FluxBuffer class
1 parent 61e0114 commit b4ba2d5

File tree

1 file changed

+3
-9
lines changed

1 file changed

+3
-9
lines changed

reactor-core/src/main/java/reactor/core/publisher/FluxBuffer.java

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -69,15 +69,9 @@ final class FluxBuffer<T, C extends Collection<? super T>> extends InternalFluxO
6969

7070
@Override
7171
public CoreSubscriber<? super T> subscribeOrReturn(CoreSubscriber<? super C> actual) {
72-
if (size == skip) {
73-
return new BufferExactSubscriber<>(actual, size, bufferSupplier);
74-
}
75-
else if (skip > size) {
76-
return new BufferSkipSubscriber<>(actual, size, skip, bufferSupplier);
77-
}
78-
else {
79-
return new BufferOverlappingSubscriber<>(actual, size, skip, bufferSupplier);
80-
}
72+
return (size == skip) ? new BufferExactSubscriber<>(actual, size, bufferSupplier) :
73+
(skip > size) ? new BufferSkipSubscriber<>(actual, size, skip, bufferSupplier) :
74+
new BufferOverlappingSubscriber<>(actual, size, skip, bufferSupplier);
8175
}
8276

8377
@Override

0 commit comments

Comments
 (0)