Merge pull request #2807 from artem-zinnatullin/correct-interfaces

Corrected all Java interfaces declarations

Author: benjchristensen

src/main/java/rx/Observable.java

@@ -98,7 +98,7 @@ public final static <T> Observable<T> create(OnSubscribe<T> f) {
     /**
      * Invoked when Obserable.subscribe is called.
      */
-    public static interface OnSubscribe<T> extends Action1<Subscriber<? super T>> {
+    public interface OnSubscribe<T> extends Action1<Subscriber<? super T>> {
         // cover for generics insanity
     }
 
@@ -191,7 +191,7 @@ public <R> Observable<R> compose(Transformer<? super T, ? extends R> transformer
      * Transformer function used by {@link #compose}.
      * @warn more complete description needed
      */
-    public static interface Transformer<T, R> extends Func1<Observable<T>, Observable<R>> {
+    public interface Transformer<T, R> extends Func1<Observable<T>, Observable<R>> {
         // cover for generics insanity
     }
 

src/main/java/rx/Observer.java

@@ -34,7 +34,7 @@ public interface Observer<T> {
      * <p>
      * The {@link Observable} will not call this method if it calls {@link #onError}.
      */
-    public abstract void onCompleted();
+    void onCompleted();
 
     /**
      * Notifies the Observer that the {@link Observable} has experienced an error condition.
@@ -45,7 +45,7 @@ public interface Observer<T> {
      * @param e
      *          the exception encountered by the Observable
      */
-    public abstract void onError(Throwable e);
+    void onError(Throwable e);
 
     /**
      * Provides the Observer with a new item to observe.
@@ -58,6 +58,6 @@ public interface Observer<T> {
      * @param t
      *          the item emitted by the Observable
      */
-    public abstract void onNext(T t);
+    void onNext(T t);
 
 }

src/main/java/rx/Producer.java

@@ -37,6 +37,6 @@ public interface Producer {
      * @param n the maximum number of items you want this Producer to produce, or {@code Long.MAX_VALUE} if you
      *          want the Producer to produce items at its own pace
      */
-    public void request(long n);
+    void request(long n);
 
 }

src/main/java/rx/Subscription.java

@@ -33,13 +33,13 @@ public interface Subscription {
      * This allows unregistering an {@link Subscriber} before it has finished receiving all events (i.e. before
      * onCompleted is called).
      */
-    public void unsubscribe();
+    void unsubscribe();
 
     /**
      * Indicates whether this {@code Subscription} is currently unsubscribed.
      *
      * @return {@code true} if this {@code Subscription} is currently unsubscribed, {@code false} otherwise
      */
-    public boolean isUnsubscribed();
+    boolean isUnsubscribed();
 
 }

src/main/java/rx/functions/Action0.java

@@ -19,5 +19,5 @@
  * A zero-argument action.
  */
 public interface Action0 extends Action {
-    public void call();
+    void call();
 }

src/main/java/rx/functions/Action1.java

@@ -19,5 +19,5 @@
  * A one-argument action.
  */
 public interface Action1<T1> extends Action {
-    public void call(T1 t1);
+    void call(T1 t1);
 }

src/main/java/rx/functions/Action2.java

@@ -19,5 +19,5 @@
  * A two-argument action.
  */
 public interface Action2<T1, T2> extends Action {
-    public void call(T1 t1, T2 t2);
+    void call(T1 t1, T2 t2);
 }

src/main/java/rx/functions/Action3.java

@@ -19,5 +19,5 @@
  * A three-argument action.
  */
 public interface Action3<T1, T2, T3> extends Action {
-    public void call(T1 t1, T2 t2, T3 t3);
+    void call(T1 t1, T2 t2, T3 t3);
 }

src/main/java/rx/functions/Func0.java

@@ -22,5 +22,5 @@
  */
 public interface Func0<R> extends Function, Callable<R> {
     @Override
-    public R call();
+    R call();
 }

src/main/java/rx/functions/Func1.java

@@ -19,5 +19,5 @@
  * Represents a function with one argument.
  */
 public interface Func1<T1, R> extends Function {
-    public R call(T1 t1);
+    R call(T1 t1);
 }