From d0139df89deb691b3a25506e942d41707c8afce8 Mon Sep 17 00:00:00 2001
From: basarat <basaratali@gmail.com>
Date: Tue, 10 Sep 2013 19:32:21 +1000
Subject: [PATCH] node : readable stream pipe can be piped further closes #1030

---
 node/node-tests.ts | 23 ++++++++++++++++++-----
 node/node.d.ts     |  4 ++--
 2 files changed, 20 insertions(+), 7 deletions(-)

diff --git a/node/node-tests.ts b/node/node-tests.ts
index 040b259f7..cf73c11bc 100644
--- a/node/node-tests.ts
+++ b/node/node-tests.ts
@@ -3,6 +3,7 @@
 import assert = require("assert");
 import fs = require("fs");
 import events = require("events");
+import zlib = require("zlib");
 
 assert(1 + 1 - 2 === 0, "The universe isn't how it should.");
 
@@ -24,11 +25,11 @@ fs.writeFile("thebible.txt",
     assert.ifError);
 
 fs.writeFile("Harry Potter",
-            "\"You be wizzing, Harry,\" jived Dumbledore.",
-            {
-                encoding: "ascii"
-            },
-            assert.ifError);
+    "\"You be wizzing, Harry,\" jived Dumbledore.",
+    {
+        encoding: "ascii"
+    },
+    assert.ifError);
 
 class Networker extends events.EventEmitter {
     constructor() {
@@ -36,4 +37,16 @@ class Networker extends events.EventEmitter {
 
         this.emit("mingling");
     }
+}
+
+////////////////////////////////////////////////////
+/// Stream tests : http://nodejs.org/api/stream.html
+////////////////////////////////////////////////////
+
+// http://nodejs.org/api/stream.html#stream_readable_pipe_destination_options
+function stream_readable_pipe_test() {
+    var r = fs.createReadStream('file.txt');
+    var z = zlib.createGzip();
+    var w = fs.createWriteStream('file.txt.gz');
+    r.pipe(z).pipe(w);
 }
\ No newline at end of file
diff --git a/node/node.d.ts b/node/node.d.ts
index 9500b0123..9ae2d75ae 100644
--- a/node/node.d.ts
+++ b/node/node.d.ts
@@ -998,7 +998,7 @@ declare module "stream" {
         pause(): void;
         resume(): void;
         destroy(): void;
-        pipe(destination: WritableStream, options?: { end?: boolean; }): void;
+        pipe<T extends WritableStream>(destination: T, options?: { end?: boolean; }): T;
     }
 
     export interface ReadableOptions {
@@ -1014,7 +1014,7 @@ declare module "stream" {
         pause(): void;
         resume(): void;
         destroy(): void;
-        pipe(destination: WritableStream, options?: { end?: boolean; }): void;
+        pipe<T extends WritableStream>(destination: T, options?: { end?: boolean; }): T;
         _read(): void;
         push(chunk: any, encoding?: string): boolean;
     }