fixed all the javadoc build warnings

Author: Joachim Hofer

rxjava-core/src/main/java/rx/Observable.java

@@ -19,7 +19,6 @@
 
 import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.Collection;
 import java.util.List;
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
@@ -544,7 +543,7 @@ public static <T> Observable<T> from(Iterable<? extends T> iterable) {
      * <p>Implementation note: the entire iterable sequence will be immediately emitted each time an {@link Observer} subscribes. Since this occurs before the {@link Subscription} is returned,
      * it in not possible to unsubscribe from the sequence before it completes.
      * 
-     * @param array
+     * @param items
      *            the source sequence
      * @param <T>
      *            the type of items in the {@link Iterable} sequence and the type of items to be
@@ -1434,7 +1433,7 @@ public static <T> Observable<T> mergeDelayError(Observable<? extends Observable<
     }
 
     /**
-     * This behaves like {@link #merge(Observable...)} except that if any of the merged Observables
+     * This behaves like {@link #merge(Observable, Observable)} except that if any of the merged Observables
      * notify of an error via {@link Observer#onError onError}, {@code mergeDelayError} will
      * refrain from propagating that error notification until all of the merged Observables have
      * finished emitting items.
@@ -1462,7 +1461,7 @@ public static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Obse
     }
 
     /**
-     * This behaves like {@link #merge(Observable...)} except that if any of the merged Observables
+     * This behaves like {@link #merge(Observable, Observable, Observable)} except that if any of the merged Observables
      * notify of an error via {@link Observer#onError onError}, {@code mergeDelayError} will
      * refrain from propagating that error notification until all of the merged Observables have
      * finished emitting items.
@@ -1492,7 +1491,7 @@ public static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Obse
     }
 
     /**
-     * This behaves like {@link #merge(Observable...)} except that if any of the merged Observables
+     * This behaves like {@link #merge(Observable, Observable, Observable, Observable)} except that if any of the merged Observables
      * notify of an error via {@link Observer#onError onError}, {@code mergeDelayError} will
      * refrain from propagating that error notification until all of the merged Observables have
      * finished emitting items.
@@ -1524,7 +1523,7 @@ public static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Obse
     }
 
     /**
-     * This behaves like {@link #merge(Observable...)} except that if any of the merged Observables
+     * This behaves like {@link #merge(Observable, Observable, Observable, Observable, Observable)} except that if any of the merged Observables
      * notify of an error via {@link Observer#onError onError}, {@code mergeDelayError} will
      * refrain from propagating that error notification until all of the merged Observables have
      * finished emitting items.
@@ -1558,7 +1557,7 @@ public static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Obse
     }
 
     /**
-     * This behaves like {@link #merge(Observable...)} except that if any of the merged Observables
+     * This behaves like {@link #merge(Observable, Observable, Observable, Observable, Observable, Observable)} except that if any of the merged Observables
      * notify of an error via {@link Observer#onError onError}, {@code mergeDelayError} will
      * refrain from propagating that error notification until all of the merged Observables have
      * finished emitting items.
@@ -1594,7 +1593,7 @@ public static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Obse
     }
 
     /**
-     * This behaves like {@link #merge(Observable...)} except that if any of the merged Observables
+     * This behaves like {@link #merge(Observable, Observable, Observable, Observable, Observable, Observable, Observable)} except that if any of the merged Observables
      * notify of an error via {@link Observer#onError onError}, {@code mergeDelayError} will
      * refrain from propagating that error notification until all of the merged Observables have
      * finished emitting items.
@@ -1632,7 +1631,7 @@ public static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Obse
     }
 
     /**
-     * This behaves like {@link #merge(Observable...)} except that if any of the merged Observables
+     * This behaves like {@link #merge(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)} except that if any of the merged Observables
      * notify of an error via {@link Observer#onError onError}, {@code mergeDelayError} will
      * refrain from propagating that error notification until all of the merged Observables have
      * finished emitting items.
@@ -1672,7 +1671,7 @@ public static <T> Observable<T> mergeDelayError(Observable<? extends T> t1, Obse
     }
 
     /**
-     * This behaves like {@link #merge(Observable...)} except that if any of the merged Observables
+     * This behaves like {@link #merge(Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable, Observable)} except that if any of the merged Observables
      * notify of an error via {@link Observer#onError onError}, {@code mergeDelayError} will
      * refrain from propagating that error notification until all of the merged Observables have
      * finished emitting items.
@@ -1832,7 +1831,7 @@ public static Observable<Long> interval(long interval, TimeUnit unit, Scheduler
      *            The {@link TimeUnit} for the timeout.
      * 
      * @return An {@link Observable} which filters out values which are too quickly followed up with newer values.
-     * @see {@link #throttleWithTimeout};
+     * @see #throttleWithTimeout(long, TimeUnit)
      */
     public Observable<T> debounce(long timeout, TimeUnit unit) {
         return create(OperationDebounce.debounce(this, timeout, unit));
@@ -1860,7 +1859,7 @@ public Observable<T> debounce(long timeout, TimeUnit unit) {
      * @param scheduler
      *            The {@link Scheduler} to use internally to manage the timers which handle timeout for each event.
      * @return Observable which performs the throttle operation.
-     * @see {@link #throttleWithTimeout};
+     * @see #throttleWithTimeout(long, TimeUnit, Scheduler)
      */
     public Observable<T> debounce(long timeout, TimeUnit unit, Scheduler scheduler) {
         return create(OperationDebounce.debounce(this, timeout, unit, scheduler));
@@ -1887,7 +1886,7 @@ public Observable<T> debounce(long timeout, TimeUnit unit, Scheduler scheduler)
      *            The {@link TimeUnit} for the timeout.
      * 
      * @return An {@link Observable} which filters out values which are too quickly followed up with newer values.
-     * @see {@link #debounce}
+     * @see #debounce(long, TimeUnit)
      */
     public Observable<T> throttleWithTimeout(long timeout, TimeUnit unit) {
         return create(OperationDebounce.debounce(this, timeout, unit));
@@ -1907,7 +1906,7 @@ public Observable<T> throttleWithTimeout(long timeout, TimeUnit unit) {
      * @param scheduler
      *            The {@link Scheduler} to use internally to manage the timers which handle timeout for each event.
      * @return Observable which performs the throttle operation.
-     * @see {@link #debounce}
+     * @see #debounce(long, TimeUnit, Scheduler)
      */
     public Observable<T> throttleWithTimeout(long timeout, TimeUnit unit, Scheduler scheduler) {
         return create(OperationDebounce.debounce(this, timeout, unit, scheduler));
@@ -1920,7 +1919,7 @@ public Observable<T> throttleWithTimeout(long timeout, TimeUnit unit, Scheduler
      * <p>
      * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/throttleFirst.png">
      * 
-     * @param skipDuration
+     * @param windowDuration
      *            Time to wait before sending another value after emitting last value.
      * @param unit
      *            The unit of time for the specified timeout.
@@ -1961,7 +1960,7 @@ public Observable<T> throttleFirst(long skipDuration, TimeUnit unit, Scheduler s
      * @param unit
      *            The unit of time for the specified interval.
      * @return Observable which performs the throttle operation.
-     * @see {@link #sample(long, TimeUnit)}
+     * @see #sample(long, TimeUnit)
      */
     public Observable<T> throttleLast(long intervalDuration, TimeUnit unit) {
         return sample(intervalDuration, unit);
@@ -1979,7 +1978,7 @@ public Observable<T> throttleLast(long intervalDuration, TimeUnit unit) {
      * @param unit
      *            The unit of time for the specified interval.
      * @return Observable which performs the throttle operation.
-     * @see {@link #sample(long, TimeUnit, Scheduler)}
+     * @see #sample(long, TimeUnit, Scheduler)
      */
     public Observable<T> throttleLast(long intervalDuration, TimeUnit unit, Scheduler scheduler) {
         return sample(intervalDuration, unit, scheduler);
@@ -2725,7 +2724,7 @@ public Observable<Observable<T>> window(int count) {
      *            The maximum size of each window before it should be emitted.
      * @param skip
      *            How many produced values need to be skipped before starting a new window. Note that when "skip" and
-     *            "count" are equals that this is the same operation as {@link Observable#window(Observable, int)}.
+     *            "count" are equals that this is the same operation as {@link #window(int)}.
      * @return
      *         An {@link Observable} which produces windows every "skipped" values containing at most
      *         "count" produced values.
@@ -3332,9 +3331,6 @@ public Observable<T> retry(int retryCount) {
      * <p>
      * For example, if an Observable fails on first time but emits [1, 2] then succeeds the second time and
      * emits [1, 2, 3, 4, 5] then the complete output would be [1, 2, 1, 2, 3, 4, 5, onCompleted].
-     * 
-     * @param retryCount
-     *            Number of retry attempts before failing.
      * @return Observable with retry logic.
      */
     public Observable<T> retry() {
@@ -3655,7 +3651,7 @@ public Observable<T> takeWhileWithIndex(final Func2<? super T, ? super Integer,
      * @return an Observable that emits only the very first item from the source, or none if the
      *         source Observable completes without emitting a single item.
      * @see <a href="http://msdn.microsoft.com/en-us/library/hh229177%28v=vs.103%29.aspx">MSDN: Observable.First</a>
-     * @see {@link #first()}
+     * @see #first()
      */
     public Observable<T> takeFirst() {
         return first();
@@ -3670,7 +3666,7 @@ public Observable<T> takeFirst() {
      * @return an Observable that emits only the very first item satisfying the given condition from the source,
      *         or none if the source Observable completes without emitting a single matching item.
      * @see <a href="http://msdn.microsoft.com/en-us/library/hh229177%28v=vs.103%29.aspx">MSDN: Observable.First</a>
-     * @see {@link #first(Func1)}
+     * @see #first(Func1)
      */
     public Observable<T> takeFirst(Func1<? super T, Boolean> predicate) {
         return first(predicate);
@@ -3810,8 +3806,6 @@ public Observable<T> startWith(Iterable<T> values) {
      * 
      * @param t1
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1) {
@@ -3827,8 +3821,6 @@ public Observable<T> startWith(T t1) {
      *            item to include
      * @param t2
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1, T t2) {
@@ -3846,8 +3838,6 @@ public Observable<T> startWith(T t1, T t2) {
      *            item to include
      * @param t3
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1, T t2, T t3) {
@@ -3867,8 +3857,6 @@ public Observable<T> startWith(T t1, T t2, T t3) {
      *            item to include
      * @param t4
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1, T t2, T t3, T t4) {
@@ -3890,8 +3878,6 @@ public Observable<T> startWith(T t1, T t2, T t3, T t4) {
      *            item to include
      * @param t5
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5) {
@@ -3915,8 +3901,6 @@ public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5) {
      *            item to include
      * @param t6
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6) {
@@ -3942,8 +3926,6 @@ public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6) {
      *            item to include
      * @param t7
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7) {
@@ -3971,8 +3953,6 @@ public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7) {
      *            item to include
      * @param t8
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8) {
@@ -4002,8 +3982,6 @@ public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8) {
      *            item to include
      * @param t9
      *            item to include
-     * @param values
-     *            Iterable of the items you want the modified Observable to emit first
      * @return an Observable that exhibits the modified behavior
      */
     public Observable<T> startWith(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) {

rxjava-core/src/main/java/rx/operators/ChunkedOperation.java

@@ -61,7 +61,8 @@ protected interface ChunkCreator {
      * 
      * @param <T>
      *            The type of objects which this {@link Chunk} can hold.
-     *            <C> The type of object being tracked by the {@link Chunk}
+     * @param <C> 
+     *            The type of object being tracked by the {@link Chunk}
      */
     protected abstract static class Chunk<T, C> {
         protected final List<T> contents = new ArrayList<T>();
@@ -78,7 +79,7 @@ public void pushValue(T value) {
 
         /**
          * @return
-         *         The mutable underlying {@link C} which contains all the
+         *         The mutable underlying {@code C} which contains all the
          *         recorded values in this {@link Chunk} object.
          */
         abstract public C getContents();