2.x: fix minor javadoc errors

Author: akarnokd

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

@@ -83,6 +83,7 @@ protected final void fastPathEmit(U value, boolean delayError, Disposable dispos
      * Makes sure the fast-path emits in order.
      * @param value the value to emit or queue up
      * @param delayError if true, errors are delayed until the source has terminated
+     * @param disposable the resource to dispose if the drain terminates
      */
     protected final void fastPathOrderedEmit(U value, boolean delayError, Disposable disposable) {
         final Observer<? super V> s = actual;

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

@@ -24,7 +24,7 @@
 
 /**
  * Maps the success value of the source MaybeSource into a Completable.
- * @param <T>
+ * @param <T> the value type of the source MaybeSource
  */
 public final class MaybeFlatMapCompletable<T> extends Completable {
 

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

@@ -24,7 +24,7 @@
 
 /**
  * Maps the success value of the source SingleSource into a Completable.
- * @param <T>
+ * @param <T> the value type of the source SingleSource
  */
 public final class SingleFlatMapCompletable<T> extends Completable {
 

src/main/java/io/reactivex/internal/queue/SpscArrayQueue.java

@@ -35,7 +35,7 @@
  * 2012 - Junchang- BQueue- Efficient and Practical Queuing.pdf <br>
  * </i> This implementation is wait free.
  *
- * @param <E>
+ * @param <E> the element type of the queue
  */
 public final class SpscArrayQueue<E> extends AtomicReferenceArray<E> implements SimplePlainQueue<E> {
     private static final long serialVersionUID = -1296597691183856449L;

src/main/java/io/reactivex/observers/BaseTestConsumer.java

@@ -117,6 +117,7 @@ public final int errorCount() {
      * will capture those potential errors and report it along with the original failure.
      *
      * @param message the message to use
+     * @return AssertionError the prepared AssertionError instance
      */
     protected final AssertionError fail(String message) {
         StringBuilder b = new StringBuilder(64 + message.length());

src/main/java/io/reactivex/subscribers/DefaultSubscriber.java

@@ -37,6 +37,7 @@ public final void onSubscribe(Subscription s) {
 
     /**
      * Requests from the upstream Subscription.
+     * @param n the request amount, positive
      */
     protected final void request(long n) {
         Subscription s = this.s;

src/test/java/io/reactivex/flowable/FlowableEventStream.java

@@ -66,8 +66,9 @@ public static class Event {
         public final Map<String, Object> values;
 
         /**
-         * @param type
-         * @param instanceId
+         * Construct an event with the provided parameters.
+         * @param type the event type
+         * @param instanceId the instance identifier
          * @param values
          *            This does NOT deep-copy, so do not mutate this Map after passing it in.
          */

src/test/java/io/reactivex/flowable/FlowableTests.java

@@ -699,7 +699,7 @@ public void testErrorThrownWithoutErrorHandlerSynchronous() {
      * to rethrow the exception on the thread that the message comes out from the Observable.
      * The OnCompleted behavior in this case is to do nothing."
      *
-     * @throws InterruptedException
+     * @throws InterruptedException if the await is interrupted
      */
     @Test
     @Ignore("Subscribers can't throw")

src/test/java/io/reactivex/internal/operators/flowable/BlockingFlowableNextTest.java

@@ -224,7 +224,7 @@ public void testNextWithCallingHasNextMultipleTimes() {
      * <p/>
      * This results in output such as => a: 1 b: 2 c: 89
      *
-     * @throws Throwable
+     * @throws Throwable some method call is declared throws
      */
     @Test
     public void testNoBufferingOrBlockingOfSequence() throws Throwable {

src/test/java/io/reactivex/internal/operators/flowable/FlowableGroupByTest.java

@@ -171,7 +171,7 @@ public void accept(V v) {
     /**
      * Assert that only a single subscription to a stream occurs and that all events are received.
      *
-     * @throws Throwable
+     * @throws Throwable some method call is declared throws
      */
     @Test
     public void testGroupedEventStream() throws Throwable {