const waitForEvent = require('wait-for-event-promise');
const EventEmitter = require('events')
 
(async function () {
  // create event emitter
  const emitter = new EventEmitter();
 
  // create a promise for wait for a 'hello' event
  const helloPromise = waitForEvent(emitter, 'hello');
 
  // emit a hello event
  emitter.emit('hello', {
    message: 'world'
  });
 
  // promise will resolve with the data that was emit
  const event = await helloPromise; // { message: 'world' }
  console.log(event.message); // outputs: 'world'
})();

const emitter = new EventEmitter();
 
const helloPromise = waitForEvent(emitter, 'hello', (event) => {
  return event === 'world';
});
 
emitter.emit('hello', 'bob');
// we don't care about bob, so helloPromise has not resolved yet
 
emitter.emit('hello', 'world');
// now helloPromise has resolved
 
const event = await helloPromise;
console.log(event); // outputs: 'world'

waitForEvent(emitter, 'hello', {
  filter: (value) => value === 'world'
});

const emitter = new EventEmitter();
 
// wait for 1000 ms before rejecting
const helloPromise = waitForEvent(emitter, 'hello', {
  timeout: 1000
});
 
try {
  await helloPromise;
} catch (err) {
  // after 1000 ms has passed
  console.err(err);  // err.message === "Timed out waiting for event"
}

waitForEvent(emitter, 'hello', (value) => {
  return event === 'hello';
}, { timeout: 1000 });
 
// alternatively, you can use supply the filter function in the options
waitForEvent(emitter, 'hello', {
  timeout: 1000,
  filter: (event) => event === 'world'
});

const helloPromise = waitForEvent(emitter, 'hello', {
  logger: console.debug.bind(console),
  filter: (event) => event === 'hello'
});
 
emitter.emit('hi');
emitter.emit('hey');
emitter.emit('yo');
emitter.emit('hello');