Use pump instead of pipe.

a.pipe(b).pipe(c).on('error', callback);

Error not handled for stream a and b.

var pump = require('pump');