jOOQ 3.18.7 · org.jooq.Publisher

public Interface Publisher<T>

Author

Lukas Eder

Method Summary

Modifier and Type	Method and Description
public default void	subscribe(Flow.Subscriber<? super T> the subscriber subscriber) Implements java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible.

Inherited from org.reactivestreams.Publisher:: subscribe

Method Detail

subscribe back to summary

subscribe	back to summary
public default void subscribe(Flow.Subscriber<? super T> subscriber) Implements java.util.concurrent.Flow.Publisher.subscribe. Doc from java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's `onError` method is invoked with an `IllegalStateException`. Otherwise, the Subscriber's `onSubscribe` method is invoked with a new `Subscription`. Subscribers may enable receiving items by invoking the `request` method of this Subscription, and may unsubscribe by invoking its `cancel` method. Parameters subscriber:Flow.Subscriber<? super T> the subscriber Annotations @Override

public default void subscribe(Flow.Subscriber<? super T> subscriber)

Implements java.util.concurrent.Flow.Publisher.subscribe.

Doc from java.util.concurrent.Flow.Publisher.subscribe.

Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's onError method is invoked with an IllegalStateException. Otherwise, the Subscriber's onSubscribe method is invoked with a new Subscription. Subscribers may enable receiving items by invoking the request method of this Subscription, and may unsubscribe by invoking its cancel method.

Parameters

subscriber:Flow.Subscriber<? super T>: the subscriber

Annotations

@Override