return
      }

      val body = response.body

      if (!body.isEventStream()) {
        listener.onFailure(
          this,
          IllegalStateException("Invalid content-type: ${body.contentType()}"),
          response,
        )
        return
      }

      // This is a long-lived response. Cancel full-call timeouts.
      call?.timeout()?.cancel()

///

Y luego Pydantic decodificará el string base64 y te dará los bytes originales en el campo `data` del modelo.

Recibirás una response como:

```json
{
  "description": "Some data",
  "content": "hello"
}
```

## Pydantic `bytes` para datos de salida { #pydantic-bytes-for-output-data }

            releaseNotes.getReleaseNotesCssFile().convention(extension.getSourceRoot().file("css/release-notes.css"));
            releaseNotes.getReleaseNotesJsFile().convention(extension.getSourceRoot().file("release/content/releaseIssues.js"));
            releaseNotes.getReleaseNotesAssets().convention(extension.getSourceRoot().dir("release/release-notes-assets"));
        });
    }

///

Параметр `status_code` приймає число з HTTP кодом статусу.

/// info | Інформація

`status_code` також може, як альтернативу, приймати `IntEnum`, наприклад, Python [`http.HTTPStatus`](https://docs.python.org/3/library/http.html#http.HTTPStatus).

///

Він буде:

* Повертати цей код статусу у відповіді.

    old_content = content_path.read_text(encoding="utf-8")

    new_content = yaml.dump(new_content, sort_keys=False, width=200, allow_unicode=True)
    if old_content == new_content:
        logging.info(f"The content hasn't changed for {content_path}")
        return False
    content_path.write_text(new_content, encoding="utf-8")
    logging.info(f"Updated {content_path}")
    return True


def main() -> None:

		ResponseHeaderTimeout: 15 * time.Minute, // Set conservative timeouts for MinIO internode.
		TLSHandshakeTimeout:   15 * time.Second,
		ExpectContinueTimeout: 15 * time.Second,
		// Go net/http automatically unzip if content-type is
		// gzip disable this feature, as we are always interested
		// in raw stream.
		DisableCompression: true,
	}

	return &ReconnectRESTClient{
		u:    u,
		rest: rest.NewClient(u, tr, nil),
	}
}

### Multi destination replication

import org.codelibs.fess.util.ComponentUtil;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;

/**
 * Unit tests for {@link AbstractFessFileTransformer}.
 * Tests file transformation logic including content extraction and metadata handling.
 */
public class AbstractFessFileTransformerTest extends UnitFessTestCase {

    private TestableAbstractFessFileTransformer transformer;

    @Override

/// tip | 豆知識

`aGVsbG8=` は `hello` の base64 エンコードです。

///

その後、Pydantic は base64 文字列をデコードし、モデルの `data` フィールドに元のバイト列を渡します。

次のようなレスポンスを受け取ります:

```json
{
  "description": "Some data",
  "content": "hello"
}
```

## 出力データ向けの Pydantic `bytes` { #pydantic-bytes-for-output-data }

出力データ用にモデル設定で `ser_json_bytes` とともに `bytes` フィールドを使用することもでき、Pydantic は JSON レスポンスを生成するときにバイト列を base64 でシリアライズします。

    with protocols like MCP that stream SSE over `POST`.

    The actual encoding logic lives in the FastAPI routing layer. This class
    serves mainly as a marker and sets the correct `Content-Type`.
    """

    media_type = "text/event-stream"


def _check_id_no_null(v: str | None) -> str | None:
    if v is not None and "\0" in v:
        raise ValueError("SSE 'id' must not contain null characters")