diff --git a/lib/units/storage/plugins/image/task/get.js b/lib/units/storage/plugins/image/task/get.js index 73a12ea2..6633d999 100644 --- a/lib/units/storage/plugins/image/task/get.js +++ b/lib/units/storage/plugins/image/task/get.js @@ -1,18 +1,21 @@ var util = require('util') -var http = require('http') +var stream = require('stream') var url = require('url') var Promise = require('bluebird') +var request = require('request') module.exports = function(path, options) { return new Promise(function(resolve, reject) { - http.get(url.resolve(options.storageUrl, path)) - .on('response', function(res) { + var res = request.get(url.resolve(options.storageUrl, path)) + , ret = new stream.Readable().wrap(res) // Wrap old-style stream + + res.on('response', function(res) { if (res.statusCode !== 200) { reject(new Error(util.format('HTTP %d', res.statusCode))) } else { - resolve(res) + resolve(ret) } }) .on('error', reject)