fix Unhandled stream error in pipe

Author: loulin

qiniu/io.js

@@ -50,7 +50,7 @@ function putReadable (uptoken, key, rs, extra, onret) {
 
   var form = getMultipart(uptoken, key, rs, extra);
 
-  rpc.postMultipart(conf.UP_HOST, form, onret);
+  return rpc.postMultipart(conf.UP_HOST, form, onret);
 }
 
 function put(uptoken, key, body, extra, onret) {
@@ -65,11 +65,11 @@ function put(uptoken, key, body, extra, onret) {
     var bodyCrc32 = getCrc32(body);
     extra.crc32 = '' + parseInt(bodyCrc32, 16);
   }
-  putReadable(uptoken, key, rs, extra, onret)
+  return putReadable(uptoken, key, rs, extra, onret)
 }
 
 function putWithoutKey(uptoken, body, extra, onret) {
-  put(uptoken, null, body, extra, onret);
+  return put(uptoken, null, body, extra, onret);
 }
 
 function getMultipart(uptoken, key, rs, extra) {
@@ -104,9 +104,9 @@ function putFile(uptoken, key, loadFile, extra, onret) {
     extra.mimeType = mime.lookup(loadFile);
   }
 
-  putReadable(uptoken, key, rs, extra, onret);
+  return putReadable(uptoken, key, rs, extra, onret);
 }
 
 function putFileWithoutKey(uptoken, loadFile, extra, onret) {
-  putFile(uptoken, null, loadFile, extra, onret);
+  return putFile(uptoken, null, loadFile, extra, onret);
 }

qiniu/rpc.js

@@ -7,7 +7,7 @@ exports.postWithForm = postWithForm;
 exports.postWithoutForm = postWithoutForm;
 
 function postMultipart(uri, form, onret) {
-  post(uri, form, form.headers(), onret);
+  return post(uri, form, form.headers(), onret);
 }
 
 function postWithForm(uri, form, token, onret) {
@@ -17,7 +17,7 @@ function postWithForm(uri, form, token, onret) {
   if (token) {
     headers['Authorization'] = token;
   }
-  post(uri, form, headers, onret);
+  return post(uri, form, headers, onret);
 }
 
 function postWithoutForm(uri, token, onret) {
@@ -27,7 +27,7 @@ function postWithoutForm(uri, token, onret) {
   if (token) {
     headers['Authorization'] = token;
   }
-  post(uri, null, headers, onret);
+  return post(uri, null, headers, onret);
 }
 
 function post(uri, form, headers, onresp) {
@@ -56,5 +56,7 @@ function post(uri, form, headers, onresp) {
     }
     onresp(rerr, result, res);
   });
+
+  return req;
 }