What are the rules for Subscription interface in Java 9?

A subscription can be shared by a publisher and a subscriber for the purpose of mediating the dataexchange. That's why the subscribe() method does not return the created subscription, but instead returns void. Subscriptions are only passed to subscribers through the onSubscribe() method callback. The subscription interface contains two methods: request() and cancel().

Syntax

<strong>public interface Subscription {
   public void request(long n);
   public void cancel();
}</strong>

Subscription interface rules:

• ##Subscription.request() and Subscription. The cancel() method can only be called within the context of its subscriber.
Subscriptions must allow subscribers to call the
• Subscription.request() method onNext() or the onSubscribe() method synchronously from within.
• Subscription.request() The method must set an upper limit on possible synchronization recursions between publishers and subscribers.
• Subscription.request()Methods should respect the responsiveness of their callers by returning
• Subscription.cancel()Methods must be timely by returning Returns respect the caller's responsiveness and must be thread-safe. strong>
While the subscription is not canceled, the
• Subscription.request(long n) method must register a given number of additional elements to be generated for the corresponding subscriber.
Although the subscription is not canceled,
• Subscription.request(long n) The method must call the onError() method and throw IllegalArgumentException if parameter is When the subscription is not canceled, the
• Subscription.request(long n) method may synchronously call the onNext() method on this subscriber or other subscribers.
When the subscription is not canceled, the
• Subscription.request(long n) method may call the onComplete() or onError() method synchronously .
While the subscription is not canceled, the
• Subscription.cancel() method must request the publisher to stop signaling to its subscribers. This operation does not affect the subscription immediately.
While the subscription is not canceled, the
• Subscription.cancel() method must request the publisher to delete any references to the corresponding subscription by the subscriber.
Calling the
• Subscription.cancel() and Subscription.request() methods must return normally.
• >Subscription must support an unlimited number of request calls and support a maximum of 2^63-1. If the demand is equal to or greater than 2^63-1, the publisher may consider validunbounded.

The above is the detailed content of What are the rules for Subscription interface in Java 9?. For more information, please follow other related articles on the PHP Chinese website!