node.js - 書き込み可能なストリームを実装する方法

Question

Amazon Kinesis ストリームから s3 ログまたは bunyan ログにデータをパイプしたいと考えています。

このサンプルは、ファイル書き込みストリームまたは stdout で動作します。自分の書き込み可能なストリームを実装するにはどうすればよいですか?

//this works
var file = fs.createWriteStream('my.log')
kinesisSource.pipe(file)

これは、メソッド「on」がないと言って機能しません

var stream = {}; //process.stdout works however
stream.writable = true;
stream.write =function(data){
    console.log(data);
};
kinesisSource.pipe(stream);

独自のカスタム書き込み可能ストリームに実装する必要があるメソッドは何ですか?ドキュメントは、「オン」ではなく「書き込み」を実装する必要があることを示しているようです