Skip to content

pb_client.stdio.events async

events(payloads)

Parse a hub's notifications as they arrive.

Parameters:

Name Type Description Default
payloads MemoryObjectReceiveStream[tuple[str, dict[str, Any]]]

The raw notifications, each with the method that carried it.

required

Yields:

Type Description
AsyncGenerator[HubEvent, None]

One event per notification this build understands, in the order the

AsyncGenerator[HubEvent, None]

hub produced them.