wow-benchmarks/me.ahoo.wow/BenchmarkAggregateSchedulerSupplier

BenchmarkAggregateSchedulerSupplier

class BenchmarkAggregateSchedulerSupplier(schedulerPoolSize: Int = Schedulers.DEFAULT_POOL_SIZE) : AggregateSchedulerSupplier

Constructors

BenchmarkAggregateSchedulerSupplier

constructor(schedulerPoolSize: Int = Schedulers.DEFAULT_POOL_SIZE)

Functions

open override fun close()

open override fun forceStop()

getOrInitialize

open override fun getOrInitialize(namedAggregate: NamedAggregate): Scheduler

open fun stop()

open fun stop(timeout: Duration)

open override fun stopGracefully(): Mono<Void>