Corrected all Java interfaces declarations

Author: artem-zinnatullin

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);
 }

src/main/java/rx/functions/Func2.java

@@ -19,5 +19,5 @@
  * Represents a function with two arguments.
  */
 public interface Func2<T1, T2, R> extends Function {
-    public R call(T1 t1, T2 t2);
+    R call(T1 t1, T2 t2);
 }

src/main/java/rx/functions/Func3.java

@@ -19,5 +19,5 @@
  * Represents a function with three arguments.
  */
 public interface Func3<T1, T2, T3, R> extends Function {
-    public R call(T1 t1, T2 t2, T3 t3);
+    R call(T1 t1, T2 t2, T3 t3);
 }

src/main/java/rx/functions/Func4.java

@@ -19,5 +19,5 @@
  * Represents a function with four arguments.
  */
 public interface Func4<T1, T2, T3, T4, R> extends Function {
-    public R call(T1 t1, T2 t2, T3 t3, T4 t4);
+    R call(T1 t1, T2 t2, T3 t3, T4 t4);
 }

src/main/java/rx/functions/Func5.java

@@ -19,5 +19,5 @@
  * Represents a function with five arguments.
  */
 public interface Func5<T1, T2, T3, T4, T5, R> extends Function {
-    public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5);
+    R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5);
 }

src/main/java/rx/functions/Func6.java

@@ -19,5 +19,5 @@
  * Represents a function with six arguments.
  */
 public interface Func6<T1, T2, T3, T4, T5, T6, R> extends Function {
-    public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6);
+    R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6);
 }

src/main/java/rx/functions/Func7.java

@@ -19,5 +19,5 @@
  * Represents a function with seven arguments.
  */
 public interface Func7<T1, T2, T3, T4, T5, T6, T7, R> extends Function {
-    public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7);
+    R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7);
 }

src/main/java/rx/functions/Func8.java

@@ -19,5 +19,5 @@
  * Represents a function with eight arguments.
  */
 public interface Func8<T1, T2, T3, T4, T5, T6, T7, T8, R> extends Function {
-    public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8);
+    R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8);
 }

src/main/java/rx/functions/Func9.java

@@ -19,5 +19,5 @@
  * Represents a function with nine arguments.
  */
 public interface Func9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> extends Function {
-    public R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9);
+    R call(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9);
 }

src/main/java/rx/functions/FuncN.java

@@ -19,5 +19,5 @@
  * Represents a vector-argument function.
  */
 public interface FuncN<R> extends Function {
-    public R call(Object... args);
+    R call(Object... args);
 }

src/main/java/rx/internal/operators/OperatorTimeoutBase.java

@@ -36,7 +36,7 @@ class OperatorTimeoutBase<T> implements Operator<T, T> {
      * 
      * @param <T>
      */
-    /* package-private */static interface FirstTimeoutStub<T> extends
+    /* package-private */interface FirstTimeoutStub<T> extends
             Func3<TimeoutSubscriber<T>, Long, Scheduler.Worker, Subscription> {
     }
 
@@ -45,7 +45,7 @@ class OperatorTimeoutBase<T> implements Operator<T, T> {
      * 
      * @param <T>
      */
-    /* package-private */static interface TimeoutStub<T> extends
+    /* package-private */interface TimeoutStub<T> extends
             Func4<TimeoutSubscriber<T>, Long, T, Scheduler.Worker, Subscription> {
     }
 

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

@@ -44,7 +44,7 @@
 
 public class OnSubscribeUsingTest {
 
-    private static interface Resource {
+    private interface Resource {
         public String getTextFromWeb();
 
         public void dispose();