@FunctionalInterface public interface StatementFilterFunction
execute function
.
The filter is executed when a Subscriber
subscribes
to the Publisher
returned by the DatabaseClient
.
StatementFilterFunctions are typically used to specify additional details on
the Statement objects such as fetchSize
or key generation.
ExecuteFunction
Modifier and Type | Field and Description |
---|---|
static StatementFilterFunction |
EMPTY_FILTER
An empty
StatementFilterFunction that delegates to ExecuteFunction . |
Modifier and Type | Method and Description |
---|---|
default StatementFilterFunction |
andThen(StatementFilterFunction afterFilter)
Return a composed filter function that first applies this filter, and then
applies the given
"after" filter. |
Publisher<? extends Result> |
filter(Statement statement,
ExecuteFunction next)
Apply this filter to the given
Statement and ExecuteFunction . |
static final StatementFilterFunction EMPTY_FILTER
StatementFilterFunction
that delegates to ExecuteFunction
.Publisher<? extends Result> filter(Statement statement, ExecuteFunction next)
Statement
and ExecuteFunction
.
The given ExecuteFunction
represents the next entity in the chain,
to be invoked via ExecuteFunction.execute(Statement)
in
order to proceed with the execution, or not invoked to shortcut the chain.
default StatementFilterFunction andThen(StatementFilterFunction afterFilter)
"after"
filter.afterFilter
- the filter to apply after this filter