varthrough=require("through")vartest=require("tape")varduplex=require("../index")varreadable=through()varwritable=through(write)varwritten=0vardata=0varstream=duplex(writable,readable)functionwrite(){written++}stream.on("data",ondata)functionondata(){data++}test("emit and write",function(t){t.plan(2)stream.write()readable.emit("data")t.equal(written,1,"should have written once")t.equal(data,1,"should have recived once")})