diff --git a/lib/opencv.js b/lib/opencv.js
index f99607e..3eb92e7 100755
--- a/lib/opencv.js
+++ b/lib/opencv.js
@@ -65,6 +65,7 @@ ImageDataStream.prototype.end = function(b){
 
   var buf = this.data.toBuffer();
   cv.readImage(buf, function(err, im){
+    if (err) return self.emit('error', err);
     self.emit('load', im);
   });
 }
@@ -83,7 +84,7 @@ util.inherits(ObjectDetectionStream, Stream);
 ObjectDetectionStream.prototype.write = function(m){
   var self = this;
   this.classifier.detectMultiScale(m, function(err, objs){
-    if (err) throw err;
+    if (err) return self.emit('error', err);
     self.emit('data', objs, m);
   }
   , this.opts.scale