Add error handler to pump

pinojs · Feb 7, 2017 · cf1e18e · cf1e18e
1 parent a5c1db5
commit cf1e18e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pino.js b/pino.js
@@ -39,7 +39,9 @@ function pino (opts, stream) {
   if (iopts.prettyPrint) {
     var pstream = pretty(iopts.prettyPrint)
     var origStream = istream
-    pump(pstream, origStream)
+    pump(pstream, origStream, function (err) {
+      if (err) logger.emit('error', err)
+    })
     istream = pstream
   }