initReaderAndWriter(
            name = name,
            socket = socket.asBufferedSocket(),
            client = true,
          )
          loopReader(response)
        }

        override fun onFailure(
          call: Call,
          e: IOException,
        ) {
          failWebSocket(e)
        }
      },
    )
  }

      )
    val name = "MockWebServer WebSocket ${request.url.encodedPath}"

    webSocket.initReaderAndWriter(
      name = name,
      socket = socket,
      client = false,
    )

    webSocket.loopReader(fancyResponse)

    // Even if messages are no longer being read we need to wait for the connection close signal.
    socket.awaitClosed()
  }

  @Throws(IOException::class)
  private fun writeHttpResponse(