org.jooq.impl

pack-priv abstract Class AbstractRowCountQuery

Class Inheritance

extends AbstractQuery<Record>
implements RowCountQuery

All Implemented Interfaces

Known Direct Subclasses

Imports

Field Summary

Inherited from org.jooq.impl.AbstractQuery:: rendered statement statementExecutionCount

Access	Constructor and Description
pack-priv	AbstractRowCountQuery(Configuration configuration)

Modifier and Type	Method and Description
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.AbstractQuery:: bind bind cancel close connection execute execute executeAsync executeAsync isExecutable keepResultSet keepStatement keepStatement poolable prepare queryTimeout toSQLSemiColon

AbstractRowCountQuery	back to summary
pack-priv AbstractRowCountQuery(Configuration configuration)

subscribe back to summary

subscribe	back 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

public final void subscribe(Subscriber<? super Integer> subscriber)

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