Whitespace fixes

Author: akarnokd

src/main/java/io/reactivex/internal/operators/flowable/FlowableScan.java

@@ -40,7 +40,7 @@ static final class ScanSubscriber<T> implements Subscriber<T>, Subscription {
         Subscription s;
 
         T value;
-        
+
         boolean done;
 
         ScanSubscriber(Subscriber<? super T> actual, BiFunction<T, T, T> accumulator) {

src/main/java/io/reactivex/internal/operators/flowable/FlowableScanSeed.java

@@ -52,7 +52,7 @@ static final class ScanSeedSubscriber<T, R> extends SinglePostCompleteSubscriber
         private static final long serialVersionUID = -1776795561228106469L;
 
         final BiFunction<R, ? super T, R> accumulator;
-        
+
         boolean done;
 
         ScanSeedSubscriber(Subscriber<? super R> actual, BiFunction<R, ? super T, R> accumulator, R value) {
@@ -66,7 +66,7 @@ public void onNext(T t) {
             if (done) {
                 return;
             }
-            
+
             R v = value;
 
             R u;

src/main/java/io/reactivex/internal/operators/observable/ObservableScan.java

@@ -40,7 +40,7 @@ static final class ScanObserver<T> implements Observer<T>, Disposable {
         Disposable s;
 
         T value;
-        
+
         boolean done;
 
         ScanObserver(Observer<? super T> actual, BiFunction<T, T, T> accumulator) {

src/test/java/io/reactivex/flowable/FlowableScanTests.java

@@ -15,15 +15,10 @@
 
 import static org.junit.Assert.assertEquals;
 
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.concurrent.Callable;
-import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.*;
+import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicInteger;
-import java.util.concurrent.atomic.AtomicReference;
 
-import org.junit.Assert;
 import org.junit.Test;
 
 import io.reactivex.Flowable;
@@ -33,7 +28,6 @@
 
 public class FlowableScanTests {
 
-    
     @Test
     public void testUnsubscribeScan() {
 
@@ -53,7 +47,7 @@ public void accept(HashMap<String, String> v) {
             }
         });
     }
-    
+
     @Test
     public void testScanWithSeedDoesNotEmitErrorTwiceIfScanFunctionThrows() {
         final List<Throwable> list = new CopyOnWriteArrayList<Throwable>();
@@ -76,7 +70,7 @@ public void accept(Throwable t) throws Exception {
             RxJavaPlugins.reset();
         }
     }
-    
+
     @Test
     public void testScanWithSeedDoesNotEmitTerminalEventTwiceIfScanFunctionThrows() {
         final RuntimeException e = new RuntimeException();
@@ -86,7 +80,7 @@ public void testScanWithSeedDoesNotEmitTerminalEventTwiceIfScanFunctionThrows()
           .assertNoValues()
           .assertError(e);
     }
-    
+
     @Test
     public void testScanWithSeedDoesNotProcessOnNextAfterTerminalEventIfScanFunctionThrows() {
         final RuntimeException e = new RuntimeException();
@@ -103,15 +97,15 @@ public Integer apply(Integer n1, Integer n2) throws Exception {
           .assertError(e);
         assertEquals(1, count.get());
     }
-    
+
     @Test
     public void testScanWithSeedCompletesNormally() {
         Flowable.just(1,2,3).scan(0, SUM)
           .test()
           .assertValues(0, 1, 3, 6)
           .assertComplete();
     }
-    
+
     @Test
     public void testScanWithSeedWhenScanSeedProviderThrows() {
         final RuntimeException e = new RuntimeException();
@@ -130,7 +124,7 @@ public void testScanNoSeed() {
            .assertValues(1, 3, 6)
            .assertComplete();
     }
-    
+
     @Test
     public void testScanNoSeedDoesNotEmitErrorTwiceIfScanFunctionThrows() {
         final List<Throwable> list = new CopyOnWriteArrayList<Throwable>();
@@ -153,7 +147,7 @@ public void accept(Throwable t) throws Exception {
             RxJavaPlugins.reset();
         }
     }
-    
+
     @Test
     public void testScanNoSeedDoesNotEmitTerminalEventTwiceIfScanFunctionThrows() {
         final RuntimeException e = new RuntimeException();
@@ -163,7 +157,7 @@ public void testScanNoSeedDoesNotEmitTerminalEventTwiceIfScanFunctionThrows() {
           .assertValue(1)
           .assertError(e);
     }
-    
+
     @Test
     public void testScanNoSeedDoesNotProcessOnNextAfterTerminalEventIfScanFunctionThrows() {
         final RuntimeException e = new RuntimeException();
@@ -180,7 +174,7 @@ public Integer apply(Integer n1, Integer n2) throws Exception {
           .assertError(e);
         assertEquals(1, count.get());
     }
-    
+
     private static BiFunction<Integer,Integer, Integer> throwingBiFunction(final RuntimeException e) {
         return new BiFunction<Integer, Integer, Integer>() {
             @Override
@@ -197,7 +191,7 @@ public Integer apply(Integer t1, Integer t2) throws Exception {
             return t1 + t2;
         }
     };
-    
+
     private static Callable<Integer> throwingCallable(final RuntimeException e) {
         return new Callable<Integer>() {
             @Override

src/test/java/io/reactivex/internal/operators/observable/ObservableScanTest.java

@@ -304,7 +304,7 @@ public Object apply(Object a, Object b) throws Exception {
             }
         }, false, 1, 1, 0, 0);
     }
-    
+
     @Test
     public void testScanFunctionThrowsAndUpstreamErrorsDoesNotResultInTwoTerminalEvents() {
         final RuntimeException err = new RuntimeException();
@@ -338,7 +338,7 @@ public Integer apply(Integer t1, Integer t2) throws Exception {
             RxJavaPlugins.reset();
         }
     }
-    
+
     @Test
     public void testScanFunctionThrowsAndUpstreamCompletesDoesNotResultInTwoTerminalEvents() {
         final RuntimeException err = new RuntimeException();
@@ -360,7 +360,7 @@ public Integer apply(Integer t1, Integer t2) throws Exception {
         .assertError(err)
         .assertValue(1);
     }
-    
+
     @Test
     public void testScanFunctionThrowsAndUpstreamEmitsOnNextResultsInScanFunctionBeingCalledOnlyOnce() {
         final RuntimeException err = new RuntimeException();