Skip to content
Packet Loom markminiproto

miniproto.updates.manager.UpdateManager.iter_updates

miniproto.updates.manager.UpdateManager.iter_updates

Section titled “miniproto.updates.manager.UpdateManager.iter_updates”
iter_updates() -> AsyncIterator[Update]

Yield normalized public updates from the FIFO queue until the consumer is cancelled.

Yields:

  • AsyncIterator[Update] – Updates accepted by the public queue. Dropped updates and items never processed due to drainer cancellation are not yielded.
Cancellation

Stopping the manager does not end this iterator or wake a waiting consumer.

miniproto

Fast paths where they count. Explicit boundaries everywhere else.