You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: README.md
+2-2
Original file line number
Diff line number
Diff line change
@@ -134,7 +134,7 @@ public interface Subscriber<T> {
134
134
|<a name="2.2">2</a>|If a `Subscriber` suspects that its processing of signals will negatively impact its `Publisher`’s responsivity, it is RECOMMENDED that it asynchronously dispatches its signals. |
135
135
| [:bulb:](#2.2"2.2 explained") |*The intent of this rule is that a Subscriber should [not obstruct](#term_non-obstructing) the progress of the Publisher from an execution point-of-view. In other words, the Subscriber should not starve the Publisher from CPU cycles.*|
136
136
|<a name="2.3">3</a>| `Subscriber.onComplete()` and `Subscriber.onError(Throwable t)` MUSTNOT call any methods on the `Subscription` or the `Publisher`.|
137
-
| [:bulb:](#2.3"2.3 explained") |*The intent of this rule is to prevent cycles and race-conditions—between Publisher, Subsription and Subscriber—during the processing of completion signals.*|
137
+
| [:bulb:](#2.3"2.3 explained") |*The intent of this rule is to prevent cycles and race-conditions—between Publisher, Subscription and Subscriber—during the processing of completion signals.*|
138
138
|<a name="2.4">4</a>| `Subscriber.onComplete()` and `Subscriber.onError(Throwable t)` MUST consider the Subscription cancelled after having received the signal. |
139
139
| [:bulb:](#2.4"2.4 explained") |*The intent of this rule is to make sure that Subscribers respect a Publisher’s [terminal state](#term_terminal-state) signals. ASubscription is simply not valid anymore after an onComplete or onError signal has been received.*|
140
140
|<a name="2.5">5</a>|A `Subscriber` MUST call `Subscription.cancel()` on the given `Subscription` after an `onSubscribe` signal if it already has an active `Subscription`.|
@@ -192,7 +192,7 @@ public interface Subscription {
192
192
|<a name="3.12">12</a>|While the `Subscription` is not cancelled, `Subscription.cancel()` MUST request the `Publisher` to eventually stop signaling its `Subscriber`.The operation is NOTREQUIRED to affect the `Subscription` immediately. |
193
193
| [:bulb:](#3.12"3.12 explained") |*The intent of this rule is to establish that the desire to cancel a Subscription is eventually respected by the Publisher, acknowledging that it may take some time before the signal is received.*|
194
194
|<a name="3.13">13</a>|While the `Subscription` is not cancelled, `Subscription.cancel()` MUST request the `Publisher` to eventually drop any references to the corresponding subscriber. |
195
-
| [:bulb:](#3.13"3.13 explained") |*The intent of this rule is to make sure that Subsribers can be properly garbage-collected after their subscription no longer being valid. Re-subscribing with the same Subscriber object is discouraged [see [2.12](#2.12)], but this specification does not mandate that it is disallowed since that would mean having to store previously cancelled subscriptions indefinitely.*|
195
+
| [:bulb:](#3.13"3.13 explained") |*The intent of this rule is to make sure that Subscribers can be properly garbage-collected after their subscription no longer being valid. Re-subscribing with the same Subscriber object is discouraged [see [2.12](#2.12)], but this specification does not mandate that it is disallowed since that would mean having to store previously cancelled subscriptions indefinitely.*|
196
196
|<a name="3.14">14</a>|While the `Subscription` is not cancelled, calling `Subscription.cancel` MAY cause the `Publisher`, if stateful, to transition into the `shut-down` state if no other `Subscription` exists at this point [see [1.9](#1.9)].|
197
197
| [:bulb:](#3.14"3.14 explained") |*The intent of this rule is to allow forPublishers to signal `onComplete` or `onError` following `onSubscribe` fornew Subscribers in response to a cancellation signal from an existing Subscriber.* |
198
198
| <a name="3.15">15</a> | Calling `Subscription.cancel` MUST [return normally](#term_return_normally).|
0 commit comments