examples/typescript/websocket-server-pool/ws-worker_threads/requests.js

   1 // eslint-disable-next-line import/no-unresolved, n/no-missing-import
   2 import { WebSocket } from 'ws'
   3
   4 const ws = new WebSocket('ws://localhost:8080')
   5
   6 ws.on('error', console.error)
   7
   8 ws.on('open', () => {
   9   for (let i = 0; i < 60; i++) {
  10     ws.send(
  11       JSON.stringify({ type: 'echo', data: { key1: 'value1', key2: 'value2' } })
  12     )
  13   }
  14   for (let i = 0; i < 60; i++) {
  15     ws.send(JSON.stringify({ type: 'factorial', data: { number: 30 } }))
  16   }
  17 })
  18
  19 ws.on('message', message => {
  20   console.info('message received: %s', message)
  21 })