Top Constructors Methods
org.jooq.impl

pack-priv abstract Class AbstractDelegatingDMLQuery<R extends org.jooq.Record, Q extends org.jooq.impl.AbstractDMLQuery<R>>

extends AbstractDelegatingQuery<R extends Record, Q extends AbstractDMLQuery<R>>
implements RowCountQuery
Class Inheritance
All Implemented Interfaces
org.jooq.RowCountQuery, org.jooq.Publisher, java.util.concurrent.Flow.Publisher, org.reactivestreams.Publisher, org.jooq.Query, org.jooq.AttachableQueryPart, org.jooq.QueryPart, java.io.Serializable, org.jooq.Attachable, org.jooq.Statement
Known Direct Subclasses
org.jooq.impl.UpdateImpl, org.jooq.impl.InsertImpl, org.jooq.impl.DeleteImpl
Imports
java.util.concurrent.Flow, org.jooq.Record, .RowCountQuery
Author
Lukas Eder

Constructor Summary

AccessConstructor and Description
pack-priv
AbstractDelegatingDMLQuery(Q delegate)

Method Summary

Modifier and TypeMethod and Description
public final void
subscribe(Flow.Subscriber<? super Integer>
the subscriber
subscriber)

Overrides default org.jooq.Publisher.subscribe.

Adds the given Subscriber if possible.
public final void
subscribe(Subscriber<? super Integer>
the Subscriber that will consume signals from this Publisher
subscriber)

Implements org.reactivestreams.Publisher.subscribe.

Request Publisher to start streaming data.
Inherited from org.jooq.impl.AbstractDelegatingQuery:
$delegateacceptattachbindbindcancelcloseconfigurationdetachexecuteexecuteAsyncexecuteAsyncgetBindValuesgetDelegategetParamgetParamsgetSQLgetSQLisExecutablekeepStatementpoolablequeryTimeout

Constructor Detail

AbstractDelegatingDMLQueryback to summary
pack-priv AbstractDelegatingDMLQuery(Q delegate)

Method Detail

subscribeback to summary
public final void subscribe(Flow.Subscriber<? super Integer> subscriber)

Overrides default org.jooq.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 Integer>

the subscriber

Annotations
@Override
subscribeback to summary
public final void subscribe(Subscriber<? super Integer> subscriber)

Implements org.reactivestreams.Publisher.subscribe.

Doc from org.reactivestreams.Publisher.subscribe.

Request Publisher to start streaming data.

This is a "factory method" and can be called multiple times, each time starting a new Subscription.

Each Subscription will work for only a single Subscriber.

A Subscriber should only subscribe once to a single Publisher.

If the Publisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber#onError(Throwable).

Parameters
subscriber:Subscriber<? super Integer>

the Subscriber that will consume signals from this Publisher

Annotations
@Override