Skip to content

Commit de7ad73

Browse files
Styling unification. (reactive-streams#485)
* Styling unification
1 parent b008867 commit de7ad73

File tree

5 files changed

+9
-8
lines changed

5 files changed

+9
-8
lines changed

Diff for: CopyrightWaivers.txt

+1
Original file line numberDiff line numberDiff line change
@@ -46,4 +46,5 @@ olegdokuka | Oleh Dokuka, [email protected], Netifi Inc.
4646
Scottmitch | Scott Mitchell, [email protected], Apple Inc.
4747
retronym | Jason Zaugg, [email protected], Lightbend Inc.
4848
sullis | Sean Sullivan, [email protected]
49+
tomislavhofman | Tomislav Hofman, [email protected]
4950

Diff for: api/src/main/java/org/reactivestreams/Processor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
package org.reactivestreams;
1313

1414
/**
15-
* A Processor represents a processing stage—which is both a {@link Subscriber}
15+
* A {@link Processor} represents a processing stage—which is both a {@link Subscriber}
1616
* and a {@link Publisher} and obeys the contracts of both.
1717
*
1818
* @param <T> the type of element signaled to the {@link Subscriber}

Diff for: api/src/main/java/org/reactivestreams/Publisher.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,10 @@
1515
* A {@link Publisher} is a provider of a potentially unbounded number of sequenced elements, publishing them according to
1616
* the demand received from its {@link Subscriber}(s).
1717
* <p>
18-
* A {@link Publisher} can serve multiple {@link Subscriber}s subscribed {@link #subscribe(Subscriber)} dynamically
18+
* A {@link Publisher} can serve multiple {@link Subscriber}s subscribed {@link Publisher#subscribe(Subscriber)} dynamically
1919
* at various points in time.
2020
*
21-
* @param <T> the type of element signaled.
21+
* @param <T> the type of element signaled
2222
*/
2323
public interface Publisher<T> {
2424

@@ -32,7 +32,7 @@ public interface Publisher<T> {
3232
* A {@link Subscriber} should only subscribe once to a single {@link Publisher}.
3333
* <p>
3434
* If the {@link Publisher} rejects the subscription attempt or otherwise fails it will
35-
* signal the error via {@link Subscriber#onError}.
35+
* signal the error via {@link Subscriber#onError(Throwable)}.
3636
*
3737
* @param s the {@link Subscriber} that will consume signals from this {@link Publisher}
3838
*/

Diff for: api/src/main/java/org/reactivestreams/Subscriber.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,10 @@
2424
* <p>
2525
* Demand can be signaled via {@link Subscription#request(long)} whenever the {@link Subscriber} instance is capable of handling more.
2626
*
27-
* @param <T> the type of element signaled.
27+
* @param <T> the type of element signaled
2828
*/
2929
public interface Subscriber<T> {
30+
3031
/**
3132
* Invoked after calling {@link Publisher#subscribe(Subscriber)}.
3233
* <p>
@@ -36,8 +37,7 @@ public interface Subscriber<T> {
3637
* <p>
3738
* The {@link Publisher} will send notifications only in response to {@link Subscription#request(long)}.
3839
*
39-
* @param s
40-
* {@link Subscription} that allows requesting data via {@link Subscription#request(long)}
40+
* @param s the {@link Subscription} that allows requesting data via {@link Subscription#request(long)}
4141
*/
4242
public void onSubscribe(Subscription s);
4343

Diff for: api/src/main/java/org/reactivestreams/Subscription.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,9 @@
1717
* It can only be used once by a single {@link Subscriber}.
1818
* <p>
1919
* It is used to both signal desire for data and cancel demand (and allow resource cleanup).
20-
*
2120
*/
2221
public interface Subscription {
22+
2323
/**
2424
* No events will be sent by a {@link Publisher} until demand is signaled via this method.
2525
* <p>

0 commit comments

Comments
 (0)