File tree 3 files changed +2
-8
lines changed
3 files changed +2
-8
lines changed Original file line number Diff line number Diff line change 17
17
18
18
/**
19
19
* @warn javadoc description missing
20
- * @since 0.20
21
20
*/
22
21
public interface Producer {
23
22
@@ -27,7 +26,6 @@ public interface Producer {
27
26
*
28
27
* @param n the maximum number of items you want this Producer to produce, or {@code Long.MAX_VALUE} if you
29
28
* want the Producer to produce items at its own pace
30
- * @since 0.20
31
29
*/
32
30
public void request (long n );
33
31
Original file line number Diff line number Diff line change @@ -80,8 +80,6 @@ public final boolean isUnsubscribed() {
80
80
* This method is invoked when the Subscriber and Observable have been connected but the Observable has
81
81
* not yet begun to emit items or send notifications to the Subscriber. Override this method to add any
82
82
* useful initialization to your subscription, for instance to initiate backpressure.
83
- *
84
- * @since 0.20
85
83
*/
86
84
public void onStart () {
87
85
// do nothing by default
@@ -94,7 +92,6 @@ public void onStart() {
94
92
*
95
93
* @param n the maximum number of items you want the Observable to emit to the Subscriber at this time, or
96
94
* {@code Long.MAX_VALUE} if you want the Observable to emit items at its own pace
97
- * @since 0.20
98
95
*/
99
96
protected final void request (long n ) {
100
97
Producer shouldRequest = null ;
@@ -115,7 +112,6 @@ protected final void request(long n) {
115
112
* @warn javadoc description missing
116
113
* @warn param producer not described
117
114
* @param producer
118
- * @since 0.20
119
115
*/
120
116
public void setProducer (Producer producer ) {
121
117
long toRequest ;
Original file line number Diff line number Diff line change @@ -136,8 +136,8 @@ public void onNext(T t) {
136
136
/**
137
137
* Allow calling the protected {@link #request(long)} from unit tests.
138
138
*
139
- * @param n
140
- * @warn parameter "n" not described
139
+ * @param n the maximum number of items you want the Observable to emit to the Subscriber at this time, or
140
+ * {@code Long.MAX_VALUE} if you want the Observable to emit items at its own pace
141
141
*/
142
142
public void requestMore (long n ) {
143
143
request (n );
You can’t perform that action at this time.
0 commit comments