use Processor from org.reactivestream.