gistfile1.txt

import WebSocket from 'ws'

function throttle<T>(callback: (message: T) => Promise<void>, interval = 1000): (message: T) => Promise<void> {
  return (message: T) => Promise.resolve()
}

interface Message {
  type: string
  content: string
}

async function processMessage(m: Message) {
  console.log(m)
}

async function main() {
  const ws1 = new WebSocket('wss://echo.websocket.org')
  
  await new Promise(res => {
    ws1.onopen = res
  })

  ws1.onmessage = async x => {
    if (typeof x.data === 'string') {
      const message: Message = JSON.parse(x.data)
    }
  }

  ws1.send(JSON.stringify({ type: '1', content: 'content1' }))
  ws1.send(JSON.stringify({ type: '1', content: 'content2' }))
  ws1.send(JSON.stringify({ type: '2', content: 'content3' }))
  ws1.send(JSON.stringify({ type: '2', content: 'content4' }))
}

main()