Node stream Transform Implement

[kgneng2]

https://nodejs.org/api/stream.html#transform_transformchunk-encoding-callback 공식문서가 최고다.. 중요한거만 요약한다.

_transform(chunk, encoding, callback)

transform.prototype._transform = function(data, encoding, callback) {
  this.push(data);
  callback();
};

transform.prototype._transform = function(data, encoding, callback) {
  callback(null, data);
};

• 위의 두개 함수는 똑같다
• callback의 두번째 인자는 push 함수로 전달한다.. 첫번째는 error임.
• 현재 chunk가 완벽하게 consume 되었다면, callback 함수는 반드시 불려야한다.
• transform push는 0번이상 발생할수있다. (transform이 실패했으면 null이기때문..)
• decodeStrings 을 false이거나 object mode이면, 변경안해도됨.
• parallel하게 동작안하므로, 내부의 큐를 두고 다음 chunk를 받아야한다...
• 동기던, 비동기던, callback은 반드시 호출되어야한다.

_flush(callback)

• callback : 남은 데이터가 flush 되었을때 부르면 된다.
• application code에서 직접 호출하면 안됨! Reable 클래스에서 사용함
• end stream이지만, 아직 남은 데이터가 있을때 방출하기 위해서 사용함.
• Custom transform에서는 구현해야한다.
• 더이상 쓰기 데이터가 없을경우에 사용된다
• Readble에 end 이벤트가 전송되기 직전에 호출됨.
• transform.push 메소드가 0번이상 호출을 적절히 해라
• callback은 반드시 호출되어야한다.