Method send

src/api/singbox/websocket.ts:70–81

(message: MessageInitShape<Req>)

  }

  send(message: MessageInitShape<Req>) {
    const data = toBinary(this.options.requestSchema, create(this.options.requestSchema, message))
    const frame = new Uint8Array(6 + data.length)
    // frame[0]: websocket payload marker (0 = data); frame[1..5]: gRPC frame
    // header (flag + big-endian length).
    frame[2] = (data.length >>> 24) & 0xff
    frame[3] = (data.length >>> 16) & 0xff
    frame[4] = (data.length >>> 8) & 0xff
    frame[5] = data.length & 0xff
    frame.set(data, 6)
    this.enqueue(frame)
  }

  finishSend() {
    this.enqueue(FINISH_SEND)