--- /dev/null
+var through = require("through")
+var test = require("tape")
+
+var duplex = require("../index")
+
+var readable = through()
+var writable = through(write)
+var written = 0
+var data = 0
+
+var stream = duplex(writable, readable)
+
+function write() {
+ written++
+}
+
+stream.on("data", ondata)
+
+function ondata() {
+ 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")
+})