Blame view

node_modules/duplexer/test.js 434 Bytes
f7563de62   Palak Handa   first commit
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
  var duplex = require("./index")
      , assert = require("assert")
      , through = require("through")
  
  var readable = through()
      , writable = through(write)
      , written = 0
      , data = 0
  
  var stream = duplex(writable, readable)
  
  function write() {
      written++
  }
  
  stream.on("data", ondata)
  
  function ondata() {
      data++
  }
  
  stream.write()
  readable.emit("data")
  
  assert.equal(written, 1)
  assert.equal(data, 1)
  console.log("DONE")