- send
            - accept
            - receive_text
            - receive_bytes
            - receive_json
            - iter_text
            - iter_bytes
            - iter_json
            - send_text
            - send_bytes
            - send_json
            - close

## WebSockets - additional classes

Additional classes for handling WebSockets.

    name: str
    owner: User


@app.post("/users/", response_model=User)
async def create_user(user: UserCreate):
    return user


@app.get("/pets/{pet_id}", response_model=PetOut)
async def read_pet(pet_id: int):
    user = UserDB(
        email="******@****.***",
        hashed_password="secrethashed",
    )
    pet = PetDB(name="Nibbler", owner=user)
    return pet

     * </p>
     *
     * @param reader
     *            the character input stream to read from (must not be {@literal null})
     * @return the text read from the reader
     */
    public static String readText(final Reader reader) {
        assertArgumentNotNull("reader", reader);

        final StringBuilder buf = new StringBuilder(BUF_SIZE);
        CopyUtil.copy(reader, buf);
        return new String(buf);
    }

        val sType = object : TypeToken<BuildProjectToSubprojectTestClassTimes>() {}.type
        val buildProjectClassTimes = gson.fromJson<BuildProjectToSubprojectTestClassTimes>(buildClassTimeJson.readText(), sType)

        val result = mutableMapOf<TestCoverage, List<SmallSubprojectBucket>>()
        for (stage in model.stages) {
            for (testCoverage in stage.functionalTests) {

        val uuidToTestCoverage = model.stages.flatMap { it.functionalTests }.associateBy { it.uuid }
        val testCoverageAndBuckets: List<Map<String, Any>> = objectMapper.readValue(testBucketsJson.readText())
        testCoverageAndBuckets.associate { testCoverageAndBucket ->
            val testCoverage: TestCoverage = uuidToTestCoverage.getValue(testCoverageAndBucket["testCoverageUuid"].toString().toInt())

        exceptions: List<String>,
    ): Boolean {
        srcRoot.walkTopDown().forEach { file ->
            if (file.extension == "groovy" || file.extension == "java") {
                val originalText = file.readText()
                val text =
                    originalText
                        .lineSequence()
                        .filterNot { it.trim().startsWith("//") }
                        .joinToString("\n")

     */
    private fun calculateBuildFileMutation(
        projectPath: String,
        computed: Set<TargetRuntime>,
        buildFile: File
    ): BuildFileMutation {
        val lines = buildFile.readText().lines()

        val start = lines.indexOfFirst {
            Regex("\\s+computedRuntimes\\s+\\{").matches(it)
        }
        if (start == -1) {

                            new ByteArrayInputStream(Base64.getUrlDecoder().decode(hash.substring(SIMILAR_DOC_HASH_PREFIX.length())))),
                    Constants.UTF_8))) {
                return ReaderUtil.readText(reader);
            } catch (final Exception e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to decode similar document hash: hash={}", hash, e);
                }

        FileUtil.writeBytes(designJspFile.getAbsolutePath(), "ok".getBytes());
        fileList = systemHelper.refreshDesignJspFiles();
        assertEquals(1, fileList.size());
        assertEquals("ok", FileUtil.readText(fileList.get(0).toFile()));
    }

    @Test
    public void test_updateSystemProperties() {
        final SystemHelper helper = new SystemHelper();

        if (mappingMetadata == null || mappingMetadata.sourceAsMap().isEmpty()) {
            final AcknowledgedResponse putMappingResponse = fesenClient.get(c -> {
                final String source = FileUtil.readText("mapping/" + mappingName + ".json");
                return c.admin().indices().preparePutMapping(index).setSource(source, XContentType.JSON).execute();
            });
            if (putMappingResponse.isAcknowledged()) {