update typing
This commit is contained in:
parent
7e972a39f9
commit
34ab54ebff
@ -52,9 +52,9 @@ type InternalQueueMsg = {
|
||||
} & InternalMessage
|
||||
|
||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||
type Consumer<T = any> = (content: T, msg: ConsumeMessage) => Promise<void>
|
||||
type Consumer<T = any> = (content: T, msg: ConsumeMessage) => Promise<void> | void
|
||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||
type Subscriber<T = any> = (content: T, msg: ConsumeMessage) => Promise<void>
|
||||
type Subscriber<T = any> = (content: T, msg: ConsumeMessage) => Promise<void> | void
|
||||
|
||||
class MessageBroker
|
||||
{
|
||||
|
Loading…
Reference in New Issue
Block a user