www.aleph1.co.uk Git - yaffs-website/blob - node_modules/end-of-stream/test.js

   1 var assert = require('assert');
   2 var eos = require('./index');
   3
   4 var expected = 6;
   5 var fs = require('fs');
   6 var net = require('net');
   7
   8 var ws = fs.createWriteStream('/dev/null');
   9 eos(ws, function(err) {
  10         expected--;
  11         assert(!!err);
  12         if (!expected) process.exit(0);
  13 });
  14 ws.close();
  15
  16 var rs = fs.createReadStream('/dev/random');
  17 eos(rs, function(err) {
  18         expected--;
  19         assert(!!err);
  20         if (!expected) process.exit(0);
  21 });
  22 rs.close();
  23
  24 var rs = fs.createReadStream(__filename);
  25 eos(rs, function(err) {
  26         expected--;
  27         assert(!err);
  28         if (!expected) process.exit(0);
  29 });
  30 rs.pipe(fs.createWriteStream('/dev/null'));
  31
  32 var socket = net.connect(50000);
  33 eos(socket, function(err) {
  34         expected--;
  35         assert(!!err);
  36         if (!expected) process.exit(0);
  37 });
  38
  39
  40 var server = net.createServer(function(socket) {
  41         eos(socket, function() {
  42                 expected--;
  43                 if (!expected) process.exit(0);
  44         });
  45         socket.destroy();
  46 }).listen(30000, function() {
  47         var socket = net.connect(30000);
  48         eos(socket, function() {
  49                 expected--;
  50                 if (!expected) process.exit(0);
  51         });
  52 });
  53
  54
  55
  56 setTimeout(function() {
  57         assert(expected === 0);
  58         process.exit(0);
  59 }, 1000);