added a WritableStream interface again

this time, it's implementing stream.Writable

lib/Stream.js

@@ -1,32 +1,32 @@
 module.exports = Stream;
 
-var Parser = require("./Parser.js");
+var Parser = require("./WritableStream.js");
 
 function Stream(options){
-	Parser.call(this, new cbs(this), options);
+	Parser.call(this, new Cbs(this), options);
 }
 
 require("util").inherits(Stream, Parser);
 
 Stream.prototype.readable = true;
 
-var cbs = function(scope){
+function Cbs(scope){
 	this.scope = scope;
-};
+}
 
 var EVENTS = require("../").EVENTS;
 
 Object.keys(EVENTS).forEach(function(name){
 	if(EVENTS[name] === 0){
-		cbs.prototype["on" + name] = function(){
+		Cbs.prototype["on" + name] = function(){
 			this.scope.emit(name);
 		};
 	} else if(EVENTS[name] === 1){
-		cbs.prototype["on" + name] = function(a){
+		Cbs.prototype["on" + name] = function(a){
 			this.scope.emit(name, a);
 		};
 	} else if(EVENTS[name] === 2){
-		cbs.prototype["on" + name] = function(a, b){
+		Cbs.prototype["on" + name] = function(a, b){
 			this.scope.emit(name, a, b);
 		};
 	} else {

lib/WritableStream.js

@@ -0,0 +1,21 @@
+module.exports = Stream;
+
+var Parser = require("./Parser.js"),
+    WritableStream = require("stream").Writable || require("readable-stream").Writable;
+
+function Stream(cbs, options){
+	var parser = this._parser = new Parser(cbs, options);
+
+	WritableStream.call(this, {decodeStrings: false});
+
+	this.once("finish", function(){
+		parser.end();
+	});
+}
+
+require("util").inherits(Stream, WritableStream);
+
+WritableStream.prototype._write = function(chunk, encoding, cb){
+	this._parser.write(chunk);
+	cb();
+};

lib/index.js

@@ -24,7 +24,7 @@ module.exports = {
 		return defineProp("Stream", require("./Stream.js"));
 	},
 	get WritableStream(){
-		return defineProp("WritableStream", this.Parser);
+		return defineProp("WritableStream", require("./WritableStream.js"));
 	},
 	get ProxyHandler(){
 		return defineProp("ProxyHandler", require("./ProxyHandler.js"));