diff --git a/lib/client.js b/lib/client.js
index 6c11495..1167711 100644
--- a/lib/client.js
+++ b/lib/client.js
@@ -176,7 +176,12 @@ SearchSource.prototype._fetchHttp = function(source, query, options, callback) {
     if(err) {
       callback(err);
     } else {
-      var response = EJSON.parse(res.content);
+      try {
+        var response = EJSON.parse(res.content);
+      } catch(e) {
+        return callback(e);
+      }
+      
       if(response.error) {
         callback(response.error);
       } else {