QЦi%SSKJrJr SSKJr SSKJrJrJrJ r SSK J r SSS0SS0SS0SSS .S .S .r \ \\4\S '"S S\ 5rS\S-S\S-4Sjr"SS\5rSSSSSS.S\\S-\"S54S\\S-\"S54S\\S-\"S54S\\S-\"S54S\\S-\"S54S\4 S jjrS!rS"r\\S#'g)$) AnnotatedAny)Doc)AfterValidator BaseModelFieldmodel_validator)StreamingResponseobjecttypestringinteger)r minimum)dataeventidretry)r properties_SSE_EVENT_SCHEMAc\rSrSrSrSrSrg)EventSourceResponseaStreaming response with `text/event-stream` media type. Use as `response_class=EventSourceResponse` on a *path operation* that uses `yield` to enable Server Sent Events (SSE) responses. Works with **any HTTP method** (`GET`, `POST`, etc.), which makes it compatible 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`. ztext/event-streamN)__name__ __module__ __qualname____firstlineno____doc__ media_type__static_attributes__rJ/var/www/html/ai-image-ml/venv/lib/python3.13/site-packages/fastapi/sse.pyrrs %Jr!rvNreturnc.UbSU;a [S5eU$)Nz)SSE 'id' must not contain null characters) ValueError)r#s r"_check_id_no_nullr($s}DEE Hr!cD\rSrSr%SrSr\\\"S54\ S'Sr \\ S-\"S54\ S'Sr \\ S-\"S54\ S 'Sr \\ S-\"\5\"S 54\ S 'Sr\\S-\"S S 9\"S54\ S'Sr\\ S-\"S54\ S'\"SS9SSj5rSrg)ServerSentEvent*aLRepresents a single Server-Sent Event. When `yield`ed from a *path operation function* that uses `response_class=EventSourceResponse`, each `ServerSentEvent` is encoded into the [SSE wire format](https://html.spec.whatwg.org/multipage/server-sent-events.html#parsing-an-event-stream) (`text/event-stream`). If you yield a plain object (dict, Pydantic model, etc.) instead, it is automatically JSON-encoded and sent as the `data:` field. All `data` values **including plain strings** are JSON-serialized. For example, `data="hello"` produces `data: "hello"` on the wire (with quotes). NaB The event payload. Can be any JSON-serializable value: a Pydantic model, dict, list, string, number, etc. It is **always** serialized to JSON: strings are quoted (`"hello"` becomes `data: "hello"` on the wire). Mutually exclusive with `raw_data`. raQ Raw string to send as the `data:` field **without** JSON encoding. Use this when you need to send pre-formatted text, HTML fragments, CSV lines, or any non-JSON payload. The string is placed directly into the `data:` field as-is. Mutually exclusive with `data`. raw_dataz Optional event type name. Maps to `addEventListener(event, ...)` on the browser. When omitted, the browser dispatches on the generic `message` event. rz Optional event ID. The browser sends this value back as the `Last-Event-ID` header on automatic reconnection. **Must not contain null (`\0`) characters.** rr)gez Optional reconnection time in **milliseconds**. Tells the browser how long to wait before reconnecting after the connection is lost. Must be a non-negative integer. rz Optional comment line(s). Comment lines start with `:` in the SSE wire format and are ignored by `EventSource` clients. Useful for keep-alive pings to prevent proxy/load-balancer timeouts. commentafter)modecPURbURb [S5eU$)NzCannot set both 'data' and 'raw_data' on the same ServerSentEvent. Use 'data' for JSON-serialized payloads or 'raw_data' for pre-formatted strings.)rr,r')selfs r"_check_data_exclusive%ServerSentEvent._check_data_exclusives. 99 T]]%>;   r!r)r$r*)rrrrrrrrr__annotations__r,strrrrr(rintrr.r r3r rr!r"r*r**sF:  )        6  i d        0  9 d        ,   d ()       .  9 d          .  Y d        '"#r!r*)data_strrrrr.r8zQ Pre-serialized data string to use as the `data:` field. rzD Optional event type name (`event:` field). rz: Optional event ID (`id:` field). rzV Optional reconnection time in milliseconds (`retry:` field). r.z@ Optional comment line(s) (`:` prefix). c/nUb+UR5HnURSU35 M UbURSU35 Ub+UR5HnURSU35 M UbURSU35 UbURSU35 URS5 URS5 SRU5RS5$) z|Build SSE wire-format bytes from **pre-serialized** data. The result always ends with ` ` (the event terminator). z: zevent: zdata: zid: zretry:  zutf-8) splitlinesappendjoinencode)r8rrrr.lineslines r"format_sse_eventrBs^E&&(D LL2dV %)  wug&''')D LL6$ )* ~ tB4[!  wug&' LL LL 99U  " "7 ++r!s: ping g.@_PING_INTERVAL)typingrr annotated_docrpydanticrrrr starlette.responsesr rdictr6r5rr(r*r7bytesrBKEEPALIVE_COMMENTrCfloatrr!r"rLs!!FF1 "(#x #2 %4S> %+ %  t d  eieb     SD, d     D,  d      D,$  d      %D,4  d      5D,D d     ED,T UD,P"r!