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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
// deno-fmt-ignore-file// deno-lint-ignore-file
// Copyright Joyent and Node contributors. All rights reserved. MIT license.// Taken from Node 16.13.0// This file is automatically generated by "node/_tools/setup.ts". Do not modify this file manually
'use strict';const common = require('../common');const assert = require('assert');const net = require('net');
const tcp = new net.Server(common.mustCall((s) => {  tcp.close();
  let buf = '';  s.setEncoding('utf8');  s.on('data', function(d) {    buf += d;  });
  s.on('end', common.mustCall(function() {    console.error('SERVER: end', buf);    assert.strictEqual(buf, "L'État, c'est moi");    s.end();  }));}));
tcp.listen(0, common.mustCall(function() {  const socket = new net.Stream({ highWaterMark: 0 });
  let connected = false;  assert.strictEqual(socket.pending, true);  socket.connect(this.address().port, common.mustCall(() => connected = true));
  assert.strictEqual(socket.pending, true);  assert.strictEqual(socket.connecting, true);  assert.strictEqual(socket.readyState, 'opening');
  // Write a string that contains a multi-byte character sequence to test that  // `bytesWritten` is incremented with the # of bytes, not # of characters.  const a = "L'État, c'est ";  const b = 'moi';
  // We're still connecting at this point so the datagram is first pushed onto  // the connect queue. Make sure that it's not added to `bytesWritten` again  // when the actual write happens.  const r = socket.write(a, common.mustCall((er) => {    console.error('write cb');    assert.ok(connected);    assert.strictEqual(socket.bytesWritten, Buffer.from(a + b).length);    assert.strictEqual(socket.pending, false);  }));  socket.on('close', common.mustCall(() => {    assert.strictEqual(socket.pending, true);  }));
  assert.strictEqual(socket.bytesWritten, Buffer.from(a).length);  assert.strictEqual(r, false);  socket.end(b);
  assert.strictEqual(socket.readyState, 'opening');}));