Skip to content

Commit

Permalink
Clean up references to fusion in MonoSubscriber comments (#3261)
Browse files Browse the repository at this point in the history
Follow up to #3245
  • Loading branch information
UgiR authored and chemicL committed Mar 7, 2023
1 parent b99e32c commit 6f4e1fe
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1732,14 +1732,13 @@ public final boolean set(Subscription s) {
/**
* A Subscriber/Subscription barrier that holds a single value at most and properly gates asynchronous behaviors
* resulting from concurrent request or cancel and onXXX signals.
* Publisher Operators using this Subscriber can be fused (implement Fuseable).
*
* @param <I> The upstream sequence type
* @param <O> The downstream sequence type
*/
public static class MonoSubscriber<I, O>
implements InnerOperator<I, O>,
Fuseable, //for constants only
Fuseable,
QueueSubscription<O> {

protected final CoreSubscriber<? super O> actual;
Expand Down Expand Up @@ -1875,8 +1874,7 @@ public void request(long n) {
if (s == CANCELLED) {
return;
}
// if the any bits 1-31 are set, we are either in fusion mode (FUSED_*)
// or request has been called (HAS_REQUEST_*)
// if any bits 1-31 are set, request(n) has been called (HAS_REQUEST_*)
if ((s & ~NO_REQUEST_HAS_VALUE) != 0) {
return;
}
Expand Down

0 comments on commit 6f4e1fe

Please sign in to comment.