pytwinnet.ingestion.realtime¶

Classes

RealTimeMonitor(twin, source[, on_applied])

class pytwinnet.ingestion.realtime.RealTimeMonitor(twin, source, on_applied=None)[source]¶

Bases: object

Parameters:

twin (DigitalTwin)
source (DataSource)
on_applied (Callable[[object], None] | None)

on_applied: Optional[Callable[[object], None]] = None¶

poll_once(updates=None)[source]¶

Return type:: int
Parameters:: updates (Iterable[object] | None)

source: DataSource¶

twin: DigitalTwin¶