Sse

infra.adapters.sse

SSEInMemoryBus — in-memory event bus for SSE progress events.

Buffer published progress events so they can be replayed per fetch request.

1	`SSEInMemoryBus()`

Bases: Generic[T]

Buffer SSE progress events in memory.

Attributes:

Name	Type	Description
`_events`	`List[T]`	Events published since the last clear.

Initialize an empty event buffer.

clear() -> None

Remove all buffered events.

get_events(fr_id: str) -> List[T]

Return buffered events for a fetch request.

Parameters:

Name	Type	Description	Default
`fr_id`	`str`	Fetch request identifier to filter by.	required

Returns:

Type	Description
`List[T]`	List[T]: Events whose `fetch_request_id` equals `fr_id`.

publish(event: T) -> None

Append an event to the buffer.

Parameters:

Name	Type	Description	Default
`event`	`T`	Event to append.	required