Adds paragraph breaks to JavaDoc

Author: viktorklang

spi/src/main/java/org/reactivestreams/api/Consumer.java

@@ -6,7 +6,7 @@
  * A Consumer is the logical sink of elements of a given type.
  * The underlying implementation is done by way of a {@link org.reactivestreams.spi.Subscriber Subscriber}.
  * This interface is the user-level API for a sink while a Subscriber is the SPI.
- * 
+ * <p>
  * Implementations of this interface will typically offer domain- or language-specific
  * methods for transforming or otherwise interacting with the stream of elements.
  */
@@ -15,7 +15,6 @@ public interface Consumer<T> {
   /**
    * Get the underlying {@link org.reactivestreams.spi.Subscriber Subscriber} for this Consumer. This method should only be used by
    * implementations of this API.
-   * 
    * @return the underlying subscriber for this consumer
    */
   public Subscriber<T> getSubscriber();

spi/src/main/java/org/reactivestreams/api/Producer.java

@@ -7,7 +7,7 @@
  * The underlying implementation is done by way of a {@link org.reactivestreams.spi.Publisher Publisher}.
  * This interface is the user-level API for a source while a Publisher is the
  * SPI.
- * 
+ * <p>
  * Implementations of this interface will typically offer domain- or language-specific
  * methods for transforming or otherwise interacting with the produced stream of elements.
  */
@@ -16,7 +16,6 @@ public interface Producer<T> {
   /**
    * Get the underlying {@link org.reactivestreams.spi.Publisher Publisher} for this Producer. This method should only be used by
    * implementations of this API.
-   * 
    * @return the underlying publisher for this producer
    */
   public Publisher<T> getPublisher();
@@ -27,12 +26,12 @@ public interface Producer<T> {
    * underlying {@link org.reactivestreams.spi.Publisher Publisher}, which will initiate the transfer of the produced
    * stream of elements from producer to consumer until either of three things
    * happen:
+   * <p>
    * <ul>
    * <li>The stream ends normally (no more elements available).</li>
    * <li>The producer encounters a fatal error condition.</li>
    * <li>The consumer cancels the reception of more elements.</li>
    * </ul>
-   * 
    * @param consumer The consumer to register with this producer.
    */
   public void produceTo(Consumer<T> consumer);

spi/src/main/java/org/reactivestreams/spi/Publisher.java

@@ -10,7 +10,6 @@ public interface Publisher<T> {
   /**
    * Subscribe the given {@link org.reactivestreams.spi.Subscriber Subscriber} to this Publisher. A Subscriber can at most be subscribed once
    * to a given Publisher, and to at most one Publisher in total.
-   * 
    * @param subscriber The subscriber to register with this publisher.
    */
   public void subscribe(Subscriber<T> subscriber);

spi/src/main/java/org/reactivestreams/spi/Subscriber.java

@@ -11,7 +11,6 @@ public interface Subscriber<T> {
    * The {@link org.reactivestreams.spi.Publisher Publisher} generates a {@link org.reactivestreams.spi.Subscription Subscription} upon {@link org.reactivestreams.spi.Publisher#subscribe(org.reactivestreams.spi.Subscriber) subscribe} and passes
    * it on to the Subscriber named there using this method. The Publisher may choose to reject
    * the subscription request by calling {@link #onError onError} instead.
-   * 
    * @param subscription The subscription which connects this subscriber to its publisher.
    */
   public void onSubscribe(Subscription subscription);
@@ -20,28 +19,24 @@ public interface Subscriber<T> {
    * The {@link org.reactivestreams.spi.Publisher Publisher} calls this method to pass one element to this Subscriber. The element
    * must not be <code>null</code>. The Publisher must not call this method more often than
    * the Subscriber has signaled demand for via the corresponding {@link org.reactivestreams.spi.Subscription Subscription}.
-   * 
    * @param element The element that is passed from publisher to subscriber.
    */
   public void onNext(T element);
 
   /**
    * The {@link org.reactivestreams.spi.Publisher Publisher} calls this method in order to signal that it terminated normally.
-   * No more elements will be forthcoming and none of the Subscriber’s methods will be
-   * called hereafter.
+   * No more elements will be forthcoming and none of the Subscriber’s methods will be called hereafter.
    */
   public void onComplete();
 
   /**
    * The {@link org.reactivestreams.spi.Publisher Publisher} calls this method to signal that the stream of elements has failed
    * and is being aborted. The Subscriber should abort its processing as soon as possible.
-   * No more elements will be forthcoming and none of the Subscriber’s methods will be
-   * called hereafter.
-   * 
+   * No more elements will be forthcoming and none of the Subscriber’s methods will be called hereafter.
+   * <p>
    * This method is not intended to pass validation errors or similar from Publisher to Subscriber
    * in order to initiate an orderly shutdown of the exchange; it is intended only for fatal
    * failure conditions which make it impossible to continue processing further elements.
-   * 
    * @param cause An exception which describes the reason for tearing down this stream.
    */
   public void onError(Throwable cause);

spi/src/main/java/org/reactivestreams/spi/Subscription.java

@@ -20,7 +20,6 @@ public interface Subscription {
    * The number of requested elements is cumulative to the number requested previously.
    * The Publisher may eventually publish up to the requested number of elements to
    * the {@link org.reactivestreams.spi.Subscriber Subscriber} which owns this Subscription.
-   * 
    * @param elements The number of elements requested.
    */
   public void requestMore(int elements);