Merge pull request #3029 from akarnokd/TabsReplacedWithSpaces

Replaced tabs with spaces for good.

Author: akarnokd

src/main/java/rx/internal/util/PaddedAtomicIntegerBase.java

@@ -59,22 +59,22 @@ public final int getAndSet(int newValue) {
     }
 
     public final int getAndAdd(int delta) {
-    	return updater.getAndAdd(this, delta);
+        return updater.getAndAdd(this, delta);
     }
     public final int incrementAndGet() {
-    	return updater.incrementAndGet(this);
+        return updater.incrementAndGet(this);
     }
     public final int decrementAndGet() {
-    	return updater.decrementAndGet(this);
+        return updater.decrementAndGet(this);
     }
     public final int getAndIncrement() {
-    	return updater.getAndIncrement(this);
+        return updater.getAndIncrement(this);
     }
     public final int getAndDecrement() {
-    	return updater.getAndDecrement(this);
+        return updater.getAndDecrement(this);
     }
     public final int addAndGet(int delta) {
-    	return updater.addAndGet(this, delta);
+        return updater.addAndGet(this, delta);
     }
 
     @Override

src/test/java/rx/ConcatTests.java

@@ -81,11 +81,11 @@ public void testConcatWithIterableOfObservable() {
 
     @Test
     public void testConcatCovariance() {
-    	HorrorMovie horrorMovie1 = new HorrorMovie();
-    	Movie movie = new Movie();
-    	Media media = new Media();
-    	HorrorMovie horrorMovie2 = new HorrorMovie();
-    	
+        HorrorMovie horrorMovie1 = new HorrorMovie();
+        Movie movie = new Movie();
+        Media media = new Media();
+        HorrorMovie horrorMovie2 = new HorrorMovie();
+        
         Observable<Media> o1 = Observable.<Media> just(horrorMovie1, movie);
         Observable<Media> o2 = Observable.just(media, horrorMovie2);
 
@@ -102,12 +102,12 @@ public void testConcatCovariance() {
 
     @Test
     public void testConcatCovariance2() {
-    	HorrorMovie horrorMovie1 = new HorrorMovie();
-    	Movie movie = new Movie();
-    	Media media1 = new Media();
-    	Media media2 = new Media();
-    	HorrorMovie horrorMovie2 = new HorrorMovie();
-    	
+        HorrorMovie horrorMovie1 = new HorrorMovie();
+        Movie movie = new Movie();
+        Media media1 = new Media();
+        Media media2 = new Media();
+        HorrorMovie horrorMovie2 = new HorrorMovie();
+        
         Observable<Media> o1 = Observable.just(horrorMovie1, movie, media1);
         Observable<Media> o2 = Observable.just(media2, horrorMovie2);
 
@@ -125,11 +125,11 @@ public void testConcatCovariance2() {
 
     @Test
     public void testConcatCovariance3() {
-    	HorrorMovie horrorMovie1 = new HorrorMovie();
-    	Movie movie = new Movie();
-    	Media media = new Media();
-    	HorrorMovie horrorMovie2 = new HorrorMovie();
-    	
+        HorrorMovie horrorMovie1 = new HorrorMovie();
+        Movie movie = new Movie();
+        Media media = new Media();
+        HorrorMovie horrorMovie2 = new HorrorMovie();
+        
         Observable<Movie> o1 = Observable.just(horrorMovie1, movie);
         Observable<Media> o2 = Observable.just(media, horrorMovie2);
 
@@ -144,11 +144,11 @@ public void testConcatCovariance3() {
 
     @Test
     public void testConcatCovariance4() {
-    	final HorrorMovie horrorMovie1 = new HorrorMovie();
-    	final Movie movie = new Movie();
-    	Media media = new Media();
-    	HorrorMovie horrorMovie2 = new HorrorMovie();
-    	
+        final HorrorMovie horrorMovie1 = new HorrorMovie();
+        final Movie movie = new Movie();
+        Media media = new Media();
+        HorrorMovie horrorMovie2 = new HorrorMovie();
+        
         Observable<Movie> o1 = Observable.create(new OnSubscribe<Movie>() {
 
             @Override

src/test/java/rx/internal/operators/OperatorBufferTest.java

@@ -983,36 +983,36 @@ public void onNext(List<Integer> t) {
     }
     @Test(timeout = 3000)
     public void testBufferWithTimeDoesntUnsubscribeDownstream() throws InterruptedException {
-    	@SuppressWarnings("unchecked")
-    	final Observer<Object> o = mock(Observer.class);
-    	
-    	
-    	final CountDownLatch cdl = new CountDownLatch(1);
-    	Subscriber<Object> s = new Subscriber<Object>() {
-    		@Override
-    		public void onNext(Object t) {
-    			o.onNext(t);
-    		}
-    		@Override
-    		public void onError(Throwable e) {
-    			o.onError(e);
-    			cdl.countDown();
-    		}
-    		@Override
-    		public void onCompleted() {
-    			o.onCompleted();
-    			cdl.countDown();
-    		}
-    	};
-    	
-    	Observable.range(1, 1).delay(1, TimeUnit.SECONDS).buffer(2, TimeUnit.SECONDS).unsafeSubscribe(s);
-    	
-    	cdl.await();
-    	
-    	verify(o).onNext(Arrays.asList(1));
-    	verify(o).onCompleted();
-    	verify(o, never()).onError(any(Throwable.class));
-    	
-    	assertFalse(s.isUnsubscribed());
+        @SuppressWarnings("unchecked")
+        final Observer<Object> o = mock(Observer.class);
+        
+        
+        final CountDownLatch cdl = new CountDownLatch(1);
+        Subscriber<Object> s = new Subscriber<Object>() {
+            @Override
+            public void onNext(Object t) {
+                o.onNext(t);
+            }
+            @Override
+            public void onError(Throwable e) {
+                o.onError(e);
+                cdl.countDown();
+            }
+            @Override
+            public void onCompleted() {
+                o.onCompleted();
+                cdl.countDown();
+            }
+        };
+        
+        Observable.range(1, 1).delay(1, TimeUnit.SECONDS).buffer(2, TimeUnit.SECONDS).unsafeSubscribe(s);
+        
+        cdl.await();
+        
+        verify(o).onNext(Arrays.asList(1));
+        verify(o).onCompleted();
+        verify(o, never()).onError(any(Throwable.class));
+        
+        assertFalse(s.isUnsubscribed());
     }
 }

src/test/java/rx/internal/operators/OperatorOnErrorReturnTest.java

@@ -153,11 +153,11 @@ public void testBackpressure() {
         Observable.range(0, 100000)
                 .onErrorReturn(new Func1<Throwable, Integer>() {
 
-					@Override
-					public Integer call(Throwable t1) {
-						return 1;
-					}
-                	
+                    @Override
+                    public Integer call(Throwable t1) {
+                        return 1;
+                    }
+                    
                 })
                 .observeOn(Schedulers.computation())
                 .map(new Func1<Integer, Integer>() {