Skip to content

msight_core.nodes.async_source_node

msight_core.nodes.async_source_node

AsyncSourceNode

Bases: SourceNode, ABC

Base class for async source nodes that: - repeatedly await some async receive operation, - optionally process the message, - publish it into MSight, - handle gap + heartbeat + on_before/after_iteration.

Subclasses must implement
  • async _recv_once(self) -> Any (get the next raw message, or raise StopAsyncIteration to stop)
Optionally override
  • async _async_setup(self)
  • on_message(self, data)

on_message(data)

Optional data processing hook.

Default: pass-through. Subclasses often want to wrap into a Data type (e.g., BytesData).