Blame view

node_modules/duplexer/test/index.js 524 Bytes
2a09d1a4   liuqimichale   添加宜春 天水 宣化
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 recived once")
  })