Socket.setLoop

setLoop(callback: (() => void)): void

import ws from 'pts/ws';
import { check, sleep } from 'pts';

export default function () {
  const res = ws.connect('ws://mockwebsocket.pts.svc.cluster.local/echo', function (socket) {
    socket.on('open', () => console.log('connected'));
    socket.on('message', (data) => console.log('Message received: ', data));
    socket.on('close', () => console.log('disconnected'));
    socket.send('message');
    socket.sendBinary(new ArrayBuffer(1));
    socket.setTimeout(function () {
      console.log('3 seconds passed, closing the socket');
      socket.close();
    }, 3000);
    socket.setInterval(function () {
      socket.ping();
    }, 500);
    // 设置循环执行函数
    socket.setLoop(function () {
      sleep(0.1);
      socket.send('loop message');
    });
  });
  check('status is 101', () => res.status === 101);
}