Publisher is a provider of an unlimited number of sorted elements, publishing these elements on demand from subscribers. The Publisher8742468051c85b06f0a0af9e3e506b5c interface is responsible for publishing elements of type T and providing subscribers with the subscribe() method to connect to it.
<strong>public interface Publisher<T> {
public void subscribe(Subscriber<? super T><!--? super T--> s);
}</strong>
Rules for the Publisher interface:
-
onNext() Total number of methods signaled by Publisher The total number of elements arriving to subscriber must always be less than or equal to the total number of elements requested by subscribersubscription.
-
The publisher may emit fewer onNext() methods than requested and terminate by calling onComplete() Subscribe to the or onError() method.
-
onSubscribe(), onNext(), onError() and # that signal subscribers ##onComplete() The method must continuously emit signals.
If the publisher fails, it must signal the - >onError() method.
If the Publisher terminates successfully, it must signal the - onComplete() method.
If the Publisher signals the - onError() or onComplete() method on the subscriber, the subscriber must be unsubscribed.
Once a terminal state occurs if a subscription is canceled, its subscribers must stop receiving signals. The -
- Publisher.subscribe() method must call the onSubscribe() method before sending any other signals to this subscriber. >Subscribers and returns normally unless the supplied Subscriber is empty. In this case, it must throw NullPointerException to the caller.
- Publisher.subscribe() The method can be called as many times as necessary with different values. per subscriber.
- Publisher can support multiple subscribers and determine whether each subscription can be unicast or multicast.
The above is the detailed content of What are the rules for Publisher interface in Java 9?. For more information, please follow other related articles on the PHP Chinese website!