Options
All
  • Public
  • Public/Protected
  • All
Menu

A Cancel Scope encapsulate a closure that can be called later on.

const { consumerTag } = await amqpChannel.consume(queue, handler)
const cancelScope = new CancelScope(async () => {
  await amqpChannel.cancel(consumerTag)
})
// later
await cancelScope.cancel()

Index

Classes

Generated using TypeDoc