diff --git a/lib/server/files.js b/lib/server/files.js
index 026f50a6..ccb4d725 100644
--- a/lib/server/files.js
+++ b/lib/server/files.js
@@ -62,7 +62,7 @@
         } else {
             name = names.shift();
             
-            pipe.create(name, write, options, function(error) {
+            pipe(name, write, options, function(error) {
                 if (error)
                     callback(error);
                 else
diff --git a/lib/server/flop.js b/lib/server/flop.js
index b7f1ef4f..13707007 100644
--- a/lib/server/flop.js
+++ b/lib/server/flop.js
@@ -101,7 +101,7 @@
                     stopOnError: true
                 }, callback);
             else
-                pipe.create(from, to, callback);
+                pipe(from, to, callback);
         });
     };
 })();
diff --git a/lib/server/pack.js b/lib/server/pack.js
index 3225ba40..1e9b9658 100644
--- a/lib/server/pack.js
+++ b/lib/server/pack.js
@@ -22,7 +22,7 @@
             };
             
             if (!is || !fstream || !tar)
-                pipe.create(from, to, options, callback);
+                pipe(from, to, options, callback);
             else
                 createTar(from, function(readStream) {
                     var dir, name,
@@ -34,7 +34,7 @@
                         to      = dir + path.sep + name + '.tar.gz';
                     }
                     
-                    pipe.create(readStream, to, options, callback);
+                    pipe(readStream, to, options, callback);
                 });
         });
     };
@@ -55,7 +55,7 @@
             write   = to;
         }
         
-        pipe.create(from, write, options, callback);
+        pipe(from, write, options, callback);
     };
     
     function createTar(from, callback) {
diff --git a/lib/server/pipe.js b/lib/server/pipe.js
index 67b641e2..469c8f11 100644
--- a/lib/server/pipe.js
+++ b/lib/server/pipe.js
@@ -1,13 +1,14 @@
 (function () {
     'use strict';
     
-    var Util        = require('../util'),
-        type        = Util.type,
-        fs          = require('fs'),
-        zlib        = require('zlib');
+    var fs          = require('fs'),
+        zlib        = require('zlib'),
+        
+        Util        = require('../util'),
+        type        = Util.type;
     
-    exports.create  = create;
-    exports.getBody = getBody;
+    module.exports  = create;
+    module.exports.getBody = getBody;
     
    /**
      * create pipe
diff --git a/lib/server/ponse.js b/lib/server/ponse.js
index 2bb08cfd..c23726ea 100644
--- a/lib/server/ponse.js
+++ b/lib/server/ponse.js
@@ -227,7 +227,7 @@
                         range   : range
                     };
                     
-                    pipe.create(p.name, p.response, options, function(error) {
+                    pipe(p.name, p.response, options, function(error) {
                         if (error)
                             sendError(error, params);
                     });
diff --git a/lib/server/rest/fs/get.js b/lib/server/rest/fs/get.js
index 8eb8d649..4ffc8cc3 100644
--- a/lib/server/rest/fs/get.js
+++ b/lib/server/rest/fs/get.js
@@ -45,7 +45,7 @@
                 error   = 'hash: not suported, try update node';
                 callback(Error(error));
             } else
-                pipe.create(name, hashStream, function (error) {
+                pipe(name, hashStream, function (error) {
                     var hex;
                     
                     if (!error)
diff --git a/lib/server/rest/fs/put.js b/lib/server/rest/fs/put.js
index 5a6a3a13..0dc4e87d 100644
--- a/lib/server/rest/fs/put.js
+++ b/lib/server/rest/fs/put.js
@@ -30,7 +30,7 @@
         
         switch(query) {
         default:
-            pipe.create(readStream, name, onSave);
+            pipe(readStream, name, onSave);
             break;
         
         case 'dir':