Event Bus

import { EventBus } from '@restjs/events'
 
const bus = new EventBus()
 
bus.on('user.created', async (event) => {
  console.log(event.payload)
})
 
await bus.emit('user.created', { id: 1 })

bus.on('user.*', handler)  // user.created, user.deleted
bus.on('*', handler)       // everything

bus.once('payment.confirmed', handler)
const event = await bus.waitFor('payment.confirmed', 5000)

import { OnEvent, registerEventHandlers } from '@restjs/events'
 
class Notifications {
  @OnEvent('user.created')
  async sendWelcome(event) { await sendEmail(event.payload.email) }
}
 
registerEventHandlers(new Notifications(), bus)