BlockingCommandBuilderRewriter

class BlockingCommandBuilderRewriter(val delegate: CommandBuilderRewriter, scheduler: Scheduler = Schedulers.boundedElastic()) : Decorator<CommandBuilderRewriter> , CommandBuilderRewriter

Decorator that executes command builder rewriting on a blocking scheduler.

This wrapper ensures that potentially blocking rewrite operations are executed on a separate thread pool to avoid blocking the reactive pipeline.

Parameters

delegate

the original rewriter to wrap

scheduler

the scheduler for executing blocking operations (default: boundedElastic)

See also

Constructors

Link copied to clipboard
constructor(delegate: CommandBuilderRewriter, scheduler: Scheduler = Schedulers.boundedElastic())

Properties

Link copied to clipboard
open override val delegate: CommandBuilderRewriter
Link copied to clipboard
open override val supportedCommandType: Class<*>

The command type that this rewriter supports.

Functions

Link copied to clipboard
open override fun rewrite(commandBuilder: CommandBuilder): Mono<CommandBuilder>

Rewrites the command builder, potentially modifying its properties.