BlockingCommandBuilderRewriter

constructor(delegate: CommandBuilderRewriter, scheduler: Scheduler = Schedulers.boundedElastic())

delegate

the original rewriter to wrap

scheduler

the scheduler for executing blocking operations (default: boundedElastic)