@akiroz/mqemitter
Advanced tools
Comparing version 4.2.1 to 4.2.2
@@ -7,27 +7,24 @@ /* eslint no-unused-vars: 0 */ | ||
declare module "mqemitter" { | ||
export interface MQEmitterOptions { | ||
concurrency?: number | ||
matchEmptyLevels?: boolean | ||
separator?: string | ||
wildcardOne?: string | ||
wildcardSome?: string | ||
} | ||
export interface MQEmitterOptions { | ||
concurrency?: number | ||
matchEmptyLevels?: boolean | ||
separator?: string | ||
wildcardOne?: string | ||
wildcardSome?: string | ||
} | ||
export type Message = object & { topic: string } | ||
export type Message = object & { topic: string } | ||
export interface MQEmitter { | ||
current: number | ||
concurrent: number | ||
on(topic: string, listener: (message: Message, done: () => void) => void, callback?: () => void): this | ||
emit(message: Message, callback?: (error?: Error) => void): void | ||
removeListener(topic: string, listener?: (message: Message, done: () => void) => void, callback?: () => void): void | ||
close(callback: () => void): void | ||
} | ||
export default function MQEmitter (options?: MQEmitterOptions): MQEmitter | ||
export interface MQEmitter { | ||
current: number | ||
concurrent: number | ||
on(topic: string, listener: (message: Message, done: () => void) => void, callback?: () => void): this | ||
emit(message: Message, callback?: (error?: Error) => void): void | ||
removeListener(topic: string, listener?: (message: Message, done: () => void) => void, callback?: () => void): void | ||
close(callback: () => void): void | ||
} | ||
export default function MQEmitter (options?: MQEmitterOptions): MQEmitter | ||
{ | ||
"name": "@akiroz/mqemitter", | ||
"version": "4.2.1", | ||
"version": "4.2.2", | ||
"description": "An Opinionated Message Queue with an emitter-style API", | ||
@@ -5,0 +5,0 @@ "main": "mqemitter.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
33935
756