How to use ws

index.js

GitHub: gstockha/EGG-Server

89
90
91
92
93
94
95
96
97
98
    clients[id].socket.send(msg);
}

function receiver(ws, json) {
    const tag = json.tag;
    const id = ws.id;
    switch (tag) {
        case tags["JOINED"]: //joined
            const assignedID = (clients[json.prefID] || !json.prefID) ? getID(json.prefID) : json.prefID;
            initClient(ws, assignedID, json.name);

0

0

1

See more examples

index.js

GitHub: hollaex/hollaex-kit

60
61
62
63
64
65
66
67
68
	this.ws = null;
	this.wsEvents = [];
	this.wsReconnect = true;
	this.wsReconnectInterval = 5000;
	this.wsEventListeners = null;
	this.wsConnected = () => this.ws && this.ws.readyState === WebSocket.OPEN;
}

/* Kit Operator Network Endpoints*/

207

236

14

See more examples

index.js

GitHub: szmarczak/http2-wrapper

6
7
8
9
10
11
12
13
14
15
const connect = (url, options) => {
        const ws = new WebSocket(null);
        ws._isServer = false;

        const destroy = async error => {
                ws._readyState = WebSocket.CLOSING;

                await Promise.resolve();
                ws.emit('error', error);
        };

16

223

7

See more examples

Rtsp2WsServer.js

GitHub: moyels/rtsp2ws

94
95
96
97
98
99
100
101
102
103
    params[key] = value;
  }
}

if (!Object.keys(params).includes(RTSP_URL_KEY)) {
  ws.close();
  return
}

let rtspUrl = params.url;

0

0

1

See more examples

index.js

GitHub: message163/wc

182
183
184
185
186
187
188
189
190
191
const { url } = await inquirer_1.default.prompt({
    type: "input",
    message: "请输入ws | wss 协议地址",
    name: "url"
});
const socket = new ws_1.default(url);
socket.on('open', () => {
    console.log('socket 已连接');
});
socket.on('message', (e) => {

0

1

1

See more examples

problem.md?plain=1

GitHub: workshopper/stream-adventure

4
5
6
7
8
9
10
11
12
13
To open a stream with `ws` on localhost:8099, just write:

```js
const WebSocket = require('ws')
const ws = new WebSocket('ws://localhost:8099')
const stream = WebSocket.createWebSocketStream(ws)
```

The readme for `ws` has more info if you're curious about how to
write the server side code: https://github.com/websockets/ws

326

0

50

See more examples

Rtsp2WsServer.js

GitHub: moyels/rtsp2ws

121
122
123
124
125
126
127
128
129
130
  if (that.holderNotFound(reUrlStr)) {
    return;
  }

  that.clientHolders[reUrlStr].wss.forEach(ws => {
    ws.send(data);
  });
});

mpegProcessor.on("error", (error) => {

0

0

1

See more examples

index.js

GitHub: bitfocus/companion-module-renewedvision-propresenter

1009
1010
1011
1012
1013
1014
1015
1016
1017
1018
if (!this.config.sdport || this.config.sdport < 1 || this.config.sdport > 65535) {
	this.config.sdport = this.config.port
}

// Connect to Stage Display websocket of ProPresenter
this.sdsocket = new WebSocket('ws://' + this.config.host + ':' + this.config.sdport + '/stagedisplay')

this.sdsocket.on('open', () => {
	this.log('info', 'Opened websocket to ProPresenter stage display: ' + this.config.host + ':' + this.config.sdport)
	this.sdsocket.send(

16

28

18

See more examples

index.js

GitHub: reisxd/revanced-builder

29
30
31
32
33
34
35
36
37
38
  setSettings
} = require('./wsEvents/index.js');

const app = Express();
const server = createServer(app);
const wsServer = new WebSocketServer({ server });
const wsClients = [];

app.use(fileUpload());
app.use(Express.static(join(__dirname, 'public')));

148

0

26

See more examples

article.md?plain=1

GitHub: javascript-tutorial/ru.javascript.info

285
286
287
288
289
290
291
292
293
294
});

function onSocketConnect(ws) {
  clients.add(ws);

  ws.on('message', function(message) {
    message = message.slice(0, 50); // максимальный размер сообщения 50

    for(let client of clients) {
      client.send(message);

878

0

47

See more examples

article.md?plain=1

GitHub: javascript-tutorial/ru.javascript.info

272
273
274
275
276
277
278
279
280
281
3. Когда сообщение получено: перебрать клиентов `clients` и отправить его всем.
4. Когда подключение закрыто: `clients.delete(socket)`.

```js
const ws = new require('ws');
const wss = new ws.Server({noServer: true});

const clients = new Set();

http.createServer((req, res) => {

878

0

47

See more examples