stopConsumer

@webda/bench

---

Function: stopConsumer()

stopConsumer(consumer, timeoutMs): Promise<void>

Defined in: packages/bench/src/suites/queue.ts:402

Cancel a consumer and wait for its loop to end, at most timeoutMs

Parameters

consumer

any

the consumer returned by consume()

timeoutMs

number

maximum wait

Returns

Promise<void>