3 var stream = require("readable-stream");
5 var duplexer2 = require("./");
7 var writable = new stream.Writable({objectMode: true}),
8 readable = new stream.Readable({objectMode: true});
10 writable._write = function _write(input, encoding, done) {
11 if (readable.push(input)) {
14 readable.once("drain", done);
18 readable._read = function _read(n) {
22 // simulate the readable thing closing after a bit
23 writable.once("finish", function() {
24 setTimeout(function() {
29 var duplex = duplexer2(writable, readable);
31 duplex.on("data", function(e) {
32 console.log("got data", JSON.stringify(e));
35 duplex.on("finish", function() {
36 console.log("got finish event");
39 duplex.on("end", function() {
40 console.log("got end event");
43 duplex.write("oh, hi there", function() {
44 console.log("finished writing");
47 duplex.end(function() {
48 console.log("finished ending");