clientReader.processNextFrame()
    callback.assertBinaryMessage(bytes)
  }

  @Test fun clientTwoFrameBinary() {
    val bytes = binaryData(200)
    data.write("0264".decodeHex()).write(bytes, 0, 100)
    data.write("8064".decodeHex()).write(bytes, 100, 100)
    clientReader.processNextFrame()
    callback.assertBinaryMessage(bytes)
  }

  @Test fun twoFrameNotContinuation() {

        .build(),
    )
    val webSocket: WebSocket = newWebSocket()
    clientListener.assertOpen()
    val server = serverListener.assertOpen()
    webSocket.send("Hello!".encodeUtf8())
    serverListener.assertBinaryMessage("Hello!".encodeUtf8())
    closeWebSockets(webSocket, server)
  }

  @Test
  fun serverMessage() {
    webServer.enqueue(
      MockResponse.Builder()
        .webSocketUpgrade(serverListener)