스트림 이벤트 함수 중에 on(’data’, 콜백) 또는 on(’end’, 콜백) 을 사용한다. data라는 이벤트와 end라는 이벤트가 발생할 때 콜백 함수를 호출하도록 이벤트를 등록한 것이다. createReadStream 같은 경우는 내부적으로 알아서 data와 end 이벤트를 호출하지만, 직접 이벤트를 만들 수도 있다.

const EventEmitter = require('events');

const myEvent = new EventEmitter();
myEvent.addListener('event1', (a) => {
  console.log('event1!!', a);
})
myEvent.on('event2', () => {
  console.log('event2');
})
myEvent.on('event2', () => {
  console.log('add event2');
})
myEvent.once('event3', () => {
  console.log('event3');
}) //한 번만 실행됨

myEvent.emit('event1', 'aa');
myEvent.emit('event1');
myEvent.emit('event2'); //add event2까지 2개가 실행됨
myEvent.emit('event2'); //add event2까지 2개가 실행됨
myEvent.emit('event3');
myEvent.emit('event3'); //once라 위에 한번 실행 후 실행안됨

myEvent.on('event4', () => {
  console.log('event4');
})
myEvent.removeAllListeners('event4');
myEvent.emit('event4'); //실행안됨

const listener = () => {
  console.log('event5??');
}
myEvent.on('event5', listener);
myEvent.emit('event5');
myEvent.removeListener('event5', listener);
myEvent.emit('event5'); //실행 안됨

console.log(myEvent.listenerCount('event2'));  //event2 개수
module.exports = myEvent;

events 모듈을 이용해 객체를 만들어본 소스이다. 객체는 이벤트 관리를 위한 메서드를 가지고 있다.

• on(eventName, callback) 이벤트 이름과 이벤트 발생 시의 콜백을 연결한다. 이렇게 연결하는 동작을 이벤트 리스닝이라고 부른다. event2 처럼 이벤트 하나에 여러 개를 달아줄 수도 있다.
• addListener(eventName, callback) on기능과 같다.
• emit(eventName) 이벤트를 호출하는 메서드이다. 이벤트 이름을 인수로 넣으면 미리 등록해뒀던 이벤트 콜백이 실행된다.
• once(eventName, callback) 한 번만 실행되는 이벤트이다.
• removeAllListeners(eventName) 이벤트에 연결된 모든 이벤트 리스너를 제거한다.
• removeListener(eventName, listener) 이벤트에 연결된 리스터를 하나씩 제거한다. 리스너를 꼭 넣어야함...
• off(eventName, callback) 노드 10 버전에서 추가된 메서드로 removeListener와 기능이 같다.
• listenerCount(eventName) 현재 리스너가 몇 개 연결되어 있는지 확인한다.

스트림에서 emit으로 data와 end를 보낸다는 걸 알 수 있게됐다. 그래서 스트림을 이용한 소스상에 on(’data’, callback), on(’end’, callback) 소스를 작성하면 해당 이벤트 작동하는 것...