1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
| 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 received once")
| })
|
|
