Fix code style

Author: akarnokd

src/main/java/io/reactivex/rxjava3/core/Flowable.java

@@ -12696,10 +12696,12 @@ public final Flowable<T> onBackpressureLatest() {
      *  <dd>{@code onBackpressureReduce} does not operate by default on a particular {@link Scheduler}.</dd>
      * </dl>
      * @param reducer the bi-function to call when there is more than one non-emitted value to downstream,
-     * the first argument of the bi-function is previous item and the second one is currently emitting from upstream
+     *                 the first argument of the bi-function is previous item and the second one is currently
+     *                 emitting from upstream
      * @return the new {@code Flowable} instance
      * @throws NullPointerException if {@code reducer} is {@code null}
      * @since 3.0.9 - experimental
+     * @see #onBackpressureReduce(Supplier, BiFunction)
      */
     @Experimental
     @CheckReturnValue
@@ -12732,11 +12734,13 @@ public final Flowable<T> onBackpressureReduce(@NonNull BiFunction<T, T, T> reduc
      *  <dt><b>Scheduler:</b></dt>
      *  <dd>{@code onBackpressureReduce} does not operate by default on a particular {@link Scheduler}.</dd>
      * </dl>
+     * @param <R> the aggregate type emitted when the downstream requests more items
      * @param supplier the factory to call to create new item of type R to pass it as the first argument to {@code reducer}.
-     * It is called when previous returned value by {@code reducer} already sent to downstream or the very first update from upstream received.
+     *                 It is called when previous returned value by {@code reducer} already sent to
+     *                 downstream or the very first update from upstream received.
      * @param reducer the bi-function to call to reduce excessive updates which downstream is not ready to receive.
-     * The first argument of type R is the object returned by {@code supplier} or result of previous {@code reducer} invocation.
-     * The second argument of type T is the current update from upstream.
+     *                The first argument of type R is the object returned by {@code supplier} or result of previous
+     *                {@code reducer} invocation. The second argument of type T is the current update from upstream.
      * @return the new {@code Flowable} instance
      * @throws NullPointerException if {@code supplier} or {@code reducer} is {@code null}
      * @see #onBackpressureReduce(BiFunction)

src/main/java/io/reactivex/rxjava3/internal/operators/flowable/AbstractBackpressureThrottlingSubscriber.java

@@ -16,7 +16,6 @@
 import io.reactivex.rxjava3.core.FlowableSubscriber;
 import io.reactivex.rxjava3.internal.subscriptions.SubscriptionHelper;
 import io.reactivex.rxjava3.internal.util.BackpressureHelper;
-import org.reactivestreams.Publisher;
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
 
@@ -26,13 +25,15 @@
 
 /**
  * Abstract base class for operators that throttle excessive updates from upstream in case if
- * downstream {@link Subscriber} is not ready to receive updates
+ * downstream {@link Subscriber} is not ready to receive updates.
  *
  * @param <T> the upstream value type
  * @param <R> the downstream value type
  */
 abstract class AbstractBackpressureThrottlingSubscriber<T, R> extends AtomicInteger implements FlowableSubscriber<T>, Subscription {
 
+    private static final long serialVersionUID = -5050301752721603566L;
+
     final Subscriber<? super R> downstream;
 
     Subscription upstream;
@@ -60,7 +61,7 @@ public void onSubscribe(Subscription s) {
     }
 
     @Override
-    abstract public void onNext(T t);
+    public abstract void onNext(T t);
 
     @Override
     public void onError(Throwable t) {

src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableOnBackpressureReduceTest.java

@@ -87,9 +87,9 @@ public void synchronousDrop() {
         ts.assertValues(1, 2);
 
         source.onNext(3);
-        source.onNext(4);//3 + 4 + 50 == 57
-        source.onNext(5);//57 + 5 + 50 == 112
-        source.onNext(6);//112 + 6 + 50 == 168
+        source.onNext(4); //3 + 4 + 50 == 57
+        source.onNext(5); //57 + 5 + 50 == 112
+        source.onNext(6); //112 + 6 + 50 == 168
 
         ts.request(2);
 
@@ -100,7 +100,7 @@ public void synchronousDrop() {
         ts.assertValues(1, 2, 168, 7);
 
         source.onNext(8);
-        source.onNext(9);//8 + 9 + 50 == 67
+        source.onNext(9); //8 + 9 + 50 == 67
         source.onComplete();
 
         ts.request(1);