@FunctionalInterface public interface StatementFilterFunction
The filter is executed when a
Subscriber subscribes to the
Publisher returned by
|Modifier and Type||Method and Description|
Return a composed filter function that first applies this filter, and then applies the given
org.reactivestreams.Publisher<? extends Result> filter(Statement statement, ExecuteFunction next)
ExecuteFunction represents the next entity in the chain, to be invoked via
ExecuteFunction.execute(Statement) invoked} in order to proceed with the exchange, or not invoked to
shortcut the chain.
Copyright © 2018–2020 Pivotal Software, Inc.. All rights reserved.