Skip to content

Commit f344818

Browse files
committed
fix #96
1 parent 290bd92 commit f344818

File tree

4 files changed

+17
-3
lines changed

4 files changed

+17
-3
lines changed

CopyrightWaivers.txt

+2
Original file line numberDiff line numberDiff line change
@@ -24,3 +24,5 @@ viktorklang | Viktor Klang, [email protected], Typesafe Inc.
2424
smaldini | Stephane Maldini, [email protected], Pivotal Software Inc.
2525
savulchik | Stanislav Savulchik, [email protected]
2626
ktoso | Konrad Malawski, [email protected], Typesafe Inc.
27+
ouertani | Slim Ouertani, [email protected]
28+

api/src/main/java/org/reactivestreams/Processor.java

+3
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,9 @@
33
/**
44
* A Processor represents a processing stage—which is both a {@link Subscriber}
55
* and a {@link Publisher} and obeys the contracts of both.
6+
*
7+
* @param <T> the type of element signaled to the {@link Subscriber}
8+
* @param <R> the type of element signaled by the {@link Publisher}
69
*/
710
public interface Processor<T, R> extends Subscriber<T>, Publisher<R> {
811
}

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

+11-2
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
package org.reactivestreams;
22

3+
/**
4+
* A {@link Publisher} is a provider of a potentially unbounded number of sequenced elements, publishing them according to
5+
* the demand received from its {@link Subscriber}(s).
6+
* <p>
7+
* A {@link Publisher} can serve multiple {@link Subscriber}s subscribed {@link #subscribe(Subscriber)}dynamically
8+
* at various points in time.
9+
*
10+
* @param <T> the type of element signaled.
11+
*/
312
public interface Publisher<T> {
413

514
/**
@@ -11,9 +20,9 @@ public interface Publisher<T> {
1120
* <p>
1221
* A {@link Subscriber} should only subscribe once to a single {@link Publisher}.
1322
* <p>
14-
* If the {@link Publisher} rejects the subscription attempt or otherwise fails it will
23+
* If the {@link Publisher} rejects the subscription attempt or otherwise fails it will
1524
* signal the error via {@link Subscriber#onError}.
16-
*
25+
*
1726
* @param s the {@link Subscriber} that will consume signals from this {@link Publisher}
1827
*/
1928
public void subscribe(Subscriber<? super T> s);

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* <p>
1414
* Demand can be signaled via {@link Subscription#request(long)} whenever the {@link Subscriber} instance is capable of handling more.
1515
*
16-
* @param <T> the Type of element signaled.
16+
* @param <T> the type of element signaled.
1717
*/
1818
public interface Subscriber<T> {
1919
/**

0 commit comments

Comments
 (0)