reactor.function.batch

Interface BatchConsumer<T>

All Superinterfaces:

Consumer<T>

All Known Implementing Classes:

DelegatingConsumer

public interface BatchConsumer<T>
extends Consumer<T>

Consumer that is notified of the start and end of a batch.

Method Summary

Modifier and Type	Method and Description
void	end() Called when a batch ends.
void	start() Called when a batch begins.

Methods inherited from interface reactor.function.Consumer

accept

Method Detail

start

void start()

Called when a batch begins.

end

void end()

Called when a batch ends.