Module jdk.incubator.adba

Package jdk.incubator.sql2

Interface RowPublisherOperation<T>

All Superinterfaces:

Operation<T>, PrimitiveOperation<T>

All Known Subinterfaces:

ParameterizedRowPublisherOperation<T>

public interface RowPublisherOperation<T>
extends Operation<T>

Method Summary

Modifier and Type	Method	Description
RowPublisherOperation<T>	onError(java.util.function.Consumer<java.lang.Throwable> handler)	Provides an error handler for this Operation.
RowPublisherOperation<T>	subscribe(java.util.concurrent.Flow.Subscriber<? super Result.RowColumn> subscriber, java.util.concurrent.CompletionStage<? extends T> result)	Subscribe to the stream of rows returned by this Operation.
RowPublisherOperation<T>	timeout(java.time.Duration minTime)	The minimum time before this Operation might be canceled automatically.

Methods inherited from interface jdk.incubator.sql2.PrimitiveOperation

submit

Method Detail

subscribe

RowPublisherOperation<T> subscribe(java.util.concurrent.Flow.Subscriber<? super Result.RowColumn> subscriber,
                                   java.util.concurrent.CompletionStage<? extends T> result)

Subscribe to the stream of rows returned by this Operation. The value of the result parameter is the result of this Operation.

Parameters:

subscriber - Not null.

result - Not null.

Returns:

this RowPublisherOperation

onError

RowPublisherOperation<T> onError(java.util.function.Consumer<java.lang.Throwable> handler)

Provides an error handler for this Operation. If execution of this Operation results in an error, before the Operation is completed, the handler is called with the Throwable as the argument. The type of the Throwable is implementation dependent.

Specified by:

onError in interface Operation<T>

Returns:

this RowPublisherOperation

timeout

RowPublisherOperation<T> timeout(java.time.Duration minTime)

The minimum time before this Operation might be canceled automatically. The default value is forever. The time is counted from the beginning of Operation execution. The Operation will not be canceled before minTime after the beginning of execution. Some time at least minTime after the beginning of execution, an attempt will be made to cancel the Operation if it has not yet completed. Implementations are encouraged to attempt to cancel within a reasonable time, though what is reasonable is implementation dependent.

Specified by:

timeout in interface Operation<T>

Parameters:

minTime - minimum time to wait before attempting to cancel

Returns:

this RowPublisherOperation