Package io.debezium.function
package io.debezium.function
-
InterfacesClassDescriptionA variant of
Consumerthat can be blocked and interrupted.BlockingFunction<T,R> A variant ofFunctionthat can be blocked and interrupted.A variant ofRunnablethat can be blocked and interrupted.ABlockingConsumerthat retains a maximum number of values in a buffer before sending them to a delegate consumer.