Todo el mundo.
Estoy tratando de aplicar un patrón de observador en mi aplicación. Pero el problema es que los suscriptores no pueden escuchar el evento. Cuando una función (useEvent.js) activó un evento, no sucedió nada. Escrito a continuación son mis códigos.
pago.js
const EventEmitter = require('events') class PaymentEvent extends EventEmitter { getPaid(paymentId) { this.emit('create', paymentId) console.log('Created') } } module.exports = PaymentEventsuscriptor.js
const PaymentEvent = require('./payment') const payment = new PaymentEvent() payment.on('create', paymentId => { console.log('Event Fired!!!')}) // Expected : 'Event Fired!!!' // Result : Nothing happened ...usarEvento.js
const PaymentEvent = require('./payment') const createPayment = async data => { const payment = await CorePayment.create(data) const paymentId = payment.id const paymentEvent = new PaymentEvent() // This parts of code will fire event! paymentEvent.getPaid(paymentId) return paymentId } ...¡Muchas gracias por adelantado!
Como ya se señaló en el comentario, está creando múltiples instancias de PaymentEvent , lo que significa que crea múltiples emisores de eventos diferentes .
En su lugar, puede crear una instancia de PaymentEvent en payment.js e importar la instancia resultante cuando la necesite:
// payment.js … module.exports = new PaymentEvent; // subscriber.js const paymentEvent = require('./payment'); paymentEvent.on(…) // useEvent.js const paymentEvent = require('./payment'); … paymentEvent.getPaid(paymentId); …