started streaming

lib/knox/client.js

@@ -14,6 +14,7 @@ var utils = require('./utils')
   , http = require('http')
   , join = require('path').join
   , mime = require('mime')
+  , sys = require('sys')
   , fs = require('fs');
 
 /**
@@ -160,6 +161,20 @@ Client.prototype.putFile = function(src, filename, headers, fn){
   });
 };
 
+Client.prototype.putStream = function(stream, filename, headers, fn){
+  var self = this;
+  if ('function' == typeof headers) fn = headers;
+  fs.stat(stream.path, function(err, stat){
+    if (err) return fn(err);
+    var req = self.put(filename, utils.merge({
+      'Content-Length': stat.size
+    }, headers));
+    sys.pump(stream, req, function(err){
+      console.log(err);
+    });
+  });
+};
+
 /**
  * GET `filename` with optional `headers`.
  *

test/ns3.test.js

@@ -113,6 +113,16 @@ module.exports = {
     });
   },
 
+  'test .putStream()': function(assert, done){
+    var stream = fs.createReadStream(jsonFixture)
+      , headers = { 'Content-Type': 'application/json' };
+    client.putStream(stream, '/test/user.json', headers, function(err, res){
+        console.log(err);
+        console.log(res.statusCode);
+        console.log(res.headers);
+    });
+  },
+
   'test .getFile()': function(assert, done){
     client.getFile('/test/user.json', function(err, res){
       assert.ok(!err);