Add newline to end of files missing a newline (ReactiveX#4979)

This is to get rid of the "No newline at end of file" warning.

DESIGN.md

@@ -595,4 +595,4 @@ Since RxJava 2.x is still JDK 6 compatible, the `QueueSubscription` can't itself
 
 Even though other modern libraries also define this interface, they live in local packages and thus non-reusable without dragging in the whole library. Therefore, until externalized and standardized, cross-library micro-fusion won't happen.
 
-A consequence of the extension of the `onSubscribe`-`Subscription` rail is that intermediate operators are no longer allowed to pass an upstream `Subscription` directly to its downstream `Subscriber.onSubscribe`. Doing so is likely to have the fused sequence skip the operator completely, losing behavior or causing runtime exceptions. Since RS `Subscriber` is an interface, operators can simply implement both `Subscriber` and `Subscription` on themselves, delegating the `request` and `cancel` calls to the upstream and calling `child.onSubscribe(this)`.
+A consequence of the extension of the `onSubscribe`-`Subscription` rail is that intermediate operators are no longer allowed to pass an upstream `Subscription` directly to its downstream `Subscriber.onSubscribe`. Doing so is likely to have the fused sequence skip the operator completely, losing behavior or causing runtime exceptions. Since RS `Subscriber` is an interface, operators can simply implement both `Subscriber` and `Subscription` on themselves, delegating the `request` and `cancel` calls to the upstream and calling `child.onSubscribe(this)`.

checkstyle.xml

@@ -40,4 +40,4 @@
     <property name="fileExtensions" value=".java"/>
   </module>
    -->
-</module>
+</module>

src/main/java/io/reactivex/CompletableEmitter.java

@@ -56,4 +56,4 @@ public interface CompletableEmitter {
      * @return true if the downstream disposed the sequence
      */
     boolean isDisposed();
-}
+}

src/main/java/io/reactivex/FlowableEmitter.java

@@ -63,4 +63,4 @@ public interface FlowableEmitter<T> extends Emitter<T> {
      * @return the serialized FlowableEmitter
      */
     FlowableEmitter<T> serialize();
-}
+}

src/main/java/io/reactivex/MaybeEmitter.java

@@ -64,4 +64,4 @@ public interface MaybeEmitter<T> {
      * @return true if the downstream cancelled the sequence
      */
     boolean isDisposed();
-}
+}

src/main/java/io/reactivex/ObservableSource.java

@@ -27,4 +27,4 @@ public interface ObservableSource<T> {
      * @throws NullPointerException if {@code observer} is null
      */
     void subscribe(Observer<? super T> observer);
-}
+}

src/main/java/io/reactivex/Observer.java

@@ -73,4 +73,4 @@ public interface Observer<T> {
      */
     void onComplete();
 
-}
+}

src/main/java/io/reactivex/SingleEmitter.java

@@ -59,4 +59,4 @@ public interface SingleEmitter<T> {
      * @return true if the downstream cancelled the sequence
      */
     boolean isDisposed();
-}
+}

src/main/java/io/reactivex/annotations/package-info.java

@@ -17,4 +17,4 @@
 /**
  * Annotations for indicating experimental and beta operators, classes, methods, types or fields.
  */
-package io.reactivex.annotations;
+package io.reactivex.annotations;

src/main/java/io/reactivex/disposables/package-info.java

@@ -19,4 +19,4 @@
  * (Disposable container types) and utility classes to construct
  * Disposables from callbacks and other types.
  */
-package io.reactivex.disposables;
+package io.reactivex.disposables;

src/main/java/io/reactivex/exceptions/CompositeException.java

@@ -286,4 +286,4 @@ private Throwable getRootCause(Throwable e) {
             root = cause;
         }
     }
-}
+}

src/main/java/io/reactivex/exceptions/package-info.java

@@ -18,4 +18,4 @@
  * Exception handling utilities, safe subscriber exception classes,
  * lifecycle exception classes.
  */
-package io.reactivex.exceptions;
+package io.reactivex.exceptions;

src/main/java/io/reactivex/flowables/package-info.java

@@ -18,4 +18,4 @@
  * Classes supporting the Flowable base reactive class: connectable and grouped
  * flowables.
  */
-package io.reactivex.flowables;
+package io.reactivex.flowables;

src/main/java/io/reactivex/functions/Cancellable.java

@@ -24,4 +24,4 @@ public interface Cancellable {
      * @throws Exception on error
      */
     void cancel() throws Exception;
-}
+}

src/main/java/io/reactivex/functions/package-info.java

@@ -18,4 +18,4 @@
  * Functional interfaces of functions and actions of arity 0 to 9 and related
  * utility classes.
  */
-package io.reactivex.functions;
+package io.reactivex.functions;

src/main/java/io/reactivex/internal/disposables/CancellableDisposable.java

@@ -54,4 +54,4 @@ public void dispose() {
             }
         }
     }
-}
+}

src/main/java/io/reactivex/internal/fuseable/package-info.java

@@ -14,4 +14,4 @@
 /**
  * Base interfaces and types for supporting operator-fusion.
  */
-package io.reactivex.internal.fuseable;
+package io.reactivex.internal.fuseable;

src/main/java/io/reactivex/internal/observers/FullArbiterObserver.java

@@ -53,4 +53,4 @@ public void onError(Throwable t) {
     public void onComplete() {
         arbiter.onComplete(s);
     }
-}
+}

src/main/java/io/reactivex/internal/observers/FutureSingleObserver.java

@@ -144,4 +144,4 @@ public void dispose() {
     public boolean isDisposed() {
         return isDone();
     }
-}
+}

src/main/java/io/reactivex/internal/observers/ResumeSingleObserver.java

@@ -50,4 +50,4 @@ public void onSuccess(T value) {
     public void onError(Throwable e) {
         actual.onError(e);
     }
-}
+}

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

@@ -182,4 +182,4 @@ public boolean isDisposed() {
             return SubscriptionHelper.isCancelled(get());
         }
     }
-}
+}

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

@@ -114,4 +114,4 @@ public void remove() {
         }
 
     }
-}
+}

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

@@ -171,4 +171,4 @@ void setWaiting() {
             waiting.set(1);
         }
     }
-}
+}

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

@@ -223,4 +223,4 @@ public void cancel() {
         }
 
     }
-}
+}

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

@@ -383,4 +383,4 @@ public void replay() {
             }
         }
     }
-}
+}

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

@@ -130,4 +130,4 @@ public boolean isDisposed() {
             return s == SubscriptionHelper.CANCELLED;
         }
     }
-}
+}

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

@@ -697,4 +697,4 @@ void drain() {
         }
     }
 
-}
+}

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

@@ -105,4 +105,4 @@ public void onComplete() {
 
         other.subscribe(otherSubscriber);
     }
-}
+}

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

@@ -450,4 +450,4 @@ public int requestFusion(int requestedMode) {
             return NONE;
         }
     }
-}
+}

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

@@ -118,4 +118,4 @@ public void onComplete() {
             actual.onComplete();
         }
     }
-}
+}

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

@@ -67,4 +67,4 @@ public void onComplete() {
             actual.onComplete();
         }
     }
-}
+}

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

@@ -685,4 +685,4 @@ public void cancel() {
             }
         }
     }
-}
+}

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

@@ -201,4 +201,4 @@ public void run() {
             }
         });
     }
-}
+}

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

@@ -417,4 +417,4 @@ public void request(long n) {
             }
         }
     }
-}
+}

src/main/java/io/reactivex/internal/operators/maybe/MaybeFlatMapCompletable.java

@@ -100,4 +100,4 @@ public void onComplete() {
             actual.onComplete();
         }
     }
-}
+}

src/main/java/io/reactivex/internal/operators/maybe/MaybeFlatMapIterableFlowable.java

@@ -292,4 +292,4 @@ public R poll() throws Exception {
         }
 
     }
-}
+}

src/main/java/io/reactivex/internal/operators/maybe/MaybeFlatMapIterableObservable.java

@@ -202,4 +202,4 @@ public R poll() throws Exception {
         }
 
     }
-}
+}

src/main/java/io/reactivex/internal/operators/maybe/MaybeToSingle.java

@@ -99,4 +99,4 @@ public void onComplete() {
             }
         }
     }
-}
+}

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

@@ -153,4 +153,4 @@ public boolean isDisposed() {
             return DisposableHelper.isDisposed(get());
         }
     }
-}
+}

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

@@ -168,4 +168,4 @@ void setWaiting() {
             waiting.set(1);
         }
     }
-}
+}

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

@@ -372,4 +372,4 @@ public void replay() {
             }
         }
     }
-}
+}

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

@@ -109,4 +109,4 @@ void run() {
             }
         }
     }
-}
+}

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

@@ -202,4 +202,4 @@ void cleanup() {
         }
     }
 
-}
+}

src/main/java/io/reactivex/internal/operators/single/SingleFlatMapIterableFlowable.java

@@ -286,4 +286,4 @@ public R poll() throws Exception {
         }
 
     }
-}
+}

src/main/java/io/reactivex/internal/operators/single/SingleFlatMapIterableObservable.java

@@ -196,4 +196,4 @@ public R poll() throws Exception {
         }
 
     }
-}
+}

src/main/java/io/reactivex/internal/schedulers/ComputationScheduler.java

@@ -195,4 +195,4 @@ static final class PoolWorker extends NewThreadWorker {
             super(threadFactory);
         }
     }
-}
+}

src/main/java/io/reactivex/internal/schedulers/IoScheduler.java

@@ -238,4 +238,4 @@ public void setExpirationTime(long expirationTime) {
             this.expirationTime = expirationTime;
         }
     }
-}
+}

src/main/java/io/reactivex/internal/schedulers/NewThreadScheduler.java

@@ -50,4 +50,4 @@ private NewThreadScheduler() {
     public Worker createWorker() {
         return new NewThreadWorker(THREAD_FACTORY);
     }
-}
+}

src/main/java/io/reactivex/internal/schedulers/NewThreadWorker.java

@@ -142,4 +142,4 @@ public void dispose() {
     public boolean isDisposed() {
         return disposed;
     }
-}
+}

src/main/java/io/reactivex/internal/schedulers/TrampolineScheduler.java

@@ -189,4 +189,4 @@ public void run() {
             }
         }
     }
-}
+}

src/main/java/io/reactivex/internal/subscribers/FullArbiterSubscriber.java

@@ -53,4 +53,4 @@ public void onError(Throwable t) {
     public void onComplete() {
         arbiter.onComplete(s);
     }
-}
+}

src/main/java/io/reactivex/internal/subscriptions/FullArbiter.java

@@ -226,4 +226,4 @@ class FullArbiterMissed extends FullArbiterPad1 {
 class FullArbiterPad2 extends FullArbiterMissed {
     volatile long p1c, p2c, p3c, p4c, p5c, p6c, p7c;
     volatile long p8c, p9c, p10c, p11c, p12c, p13c, p14c, p15c;
-}
+}

src/main/java/io/reactivex/internal/util/LinkedArrayList.java

@@ -107,4 +107,4 @@ public String toString() {
 
         return list.toString();
     }
-}
+}

src/main/java/io/reactivex/internal/util/SuppressAnimalSniffer.java

@@ -23,4 +23,4 @@
 @Target({ElementType.METHOD, ElementType.CONSTRUCTOR, ElementType.TYPE})
 public @interface SuppressAnimalSniffer {
 
-}
+}

src/main/java/io/reactivex/observables/package-info.java

@@ -18,4 +18,4 @@
  * Classes supporting the Observable base reactive class: connectable and grouped
  * observables.
  */
-package io.reactivex.observables;
+package io.reactivex.observables;

src/main/java/io/reactivex/observers/package-info.java

@@ -18,4 +18,4 @@
  * Default wrappers and implementations for Observer-based consumer classes and interfaces;
  * utility classes for creating them from callbacks.
  */
-package io.reactivex.observers;
+package io.reactivex.observers;

src/main/java/io/reactivex/plugins/package-info.java

@@ -18,4 +18,4 @@
  * Callback types and a central plugin handler class to hook into the lifecycle
  * of the base reactive types and schedulers.
  */
-package io.reactivex.plugins;
+package io.reactivex.plugins;