Axonframework, reaktif depo ile MessageDispatchInterceptor nasıl kullanılır

Set tabanlı tutarlılık doğrulama blogunu okudum ve bir gönderme engelleyicisi aracılığıyla doğrulamak istiyorum. Örneği takip ediyorum, ancak reaktif depo kullanıyorum ve bu benim için gerçekten işe yaramıyor. Hem engellemeyi hem de engellememeyi denedim. blok ile hata atar, ancak blok olmadan hiçbir şey yürütmez. işte kodum.

class SubnetCommandInterceptor : MessageDispatchInterceptor<CommandMessage<*>> {

  @Autowired
  private lateinit var privateNetworkRepository: PrivateNetworkRepository

  override fun handle(messages: List<CommandMessage<*>?>): BiFunction<Int, CommandMessage<*>, CommandMessage<*>> {
    return BiFunction<Int, CommandMessage<*>, CommandMessage<*>> { index: Int?, command: CommandMessage<*> ->
      if (CreateSubnetCommand::class.simpleName == (command.payloadType.simpleName)){
        val interceptCommand = command.payload as CreateSubnetCommand
        privateNetworkRepository
          .findById(interceptCommand.privateNetworkId)
          // ..some validation logic here ex.
          // .filter { network -> network.isSubnetOverlap() }
          .switchIfEmpty(Mono.error(IllegalArgumentException("Requested subnet is overlap with the previous subnet.")))
          // .block() also doesn't work here it throws error
         // block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-
      }
      command
    }
  }
}