@eggjs/eventbus-decorator

Usage

$3

``ts
import { EventBus } from '@eggjs/eventbus-decorator'

// Define event first.
// Ts can check event and args type for you.
declare module '@eggjs/eventbus-decorator' {
interface Events {
hello: (msg: string) => Promise;
}
}

class Foo {
@Inject()
private readonly eventBus: EventBus;

bar() {
this.eventBus.emit('hello', '01');
}
}
`

$3

Cache events in memory until uncork.

`ts
class Foo {
@Inject()
private readonly eventBus: ContextEventBus;

bar() {
this.eventBus.cork();
// ...do something
this.eventBus.emit('hello', '01');
// ...do other things

// emit all cached events
this.eventBus.uncork();
}
}
`

$3

`ts
@Event('hello')
export class Foo {
async handle(msg: string): Promise {
console.log('msg: ', msg);
}
}
`

$3


`ts
@Event('hello')
@Event('hi')
export class Foo {
async handle(msg: string): Promise {
console.log('msg: ', msg);
}
}
`

$3

inject event context if you want to know which event is being handled.
The context param must be the first param

`ts
@Event('hello')
@Event('hi')
export class Foo {
async handle(@EventContext() ctx: IEventContext, msg: string):Promise {
console.log('eventName: ', ctx.eventName);
console.log('msg: ', msg);
}
}
``