1 | var Socket = require('../')
|
2 | var test = require('tape')
|
3 |
|
4 | var SOCKET_SERVER = 'wss://echo.websocket.org'
|
5 |
|
6 | test('duplex stream: send data before "connect" event', function (t) {
|
7 | t.plan(6)
|
8 |
|
9 | var socket = new Socket(SOCKET_SERVER)
|
10 | socket.write('abc')
|
11 |
|
12 | socket.on('data', function (chunk) {
|
13 | t.ok(socket.connected)
|
14 | t.equal(chunk.toString(), 'abc', 'got correct message')
|
15 | socket.end()
|
16 | })
|
17 | socket.on('finish', function () {
|
18 | t.pass('got socket "finish"')
|
19 | t.ok(socket._writableState.finished)
|
20 | })
|
21 | socket.on('end', function () {
|
22 | t.pass('got socket "end"')
|
23 | t.ok(socket._readableState.ended)
|
24 | })
|
25 | })
|
26 |
|
27 | test('duplex stream: send data one-way', function (t) {
|
28 | t.plan(6)
|
29 |
|
30 | var socket = new Socket(SOCKET_SERVER)
|
31 | socket.on('connect', function () {
|
32 | socket.write('abc')
|
33 | })
|
34 |
|
35 | socket.on('data', function (chunk) {
|
36 | t.ok(socket.connected)
|
37 | t.equal(chunk.toString(), 'abc', 'got correct message')
|
38 | socket.end()
|
39 | })
|
40 | socket.on('finish', function () {
|
41 | t.pass('got socket "finish"')
|
42 | t.ok(socket._writableState.finished)
|
43 | })
|
44 | socket.on('end', function () {
|
45 | t.pass('got socket "end"')
|
46 | t.ok(socket._readableState.ended)
|
47 | })
|
48 | })
|