外观
mob_combat_observations API
模块说明
text
Bounded mob observations after subscription, never a complete entity snapshot.MobCombatObservations
python
class MobCombatObservationsSDK 说明：
text
Follow one explicitly owned unique ID through AddActor and combat packets.
Open before target spawn. No binding from querytarget or cached runtime IDs.
Removal, death, runtime reuse, stream errors and ambiguity permanently seal it.
PlayerState/CombatObservations validate the complete mixed stream ordering.MobCombatObservations.packet_ids
python
packet_ids = (13, 14, 27, 29)MobCombatObservations.__init__
python
def __init__(self, snapshot, *, target_unique_id)MobCombatObservations.close
python
def close(self)MobCombatObservations.state
python
def state(self)MobCombatObservations.apply
python
def apply(self, event, *, epoch, received_at)MobCombatObservations.target_unique_id
python
self.target_unique_id公开实例属性，在 __init__ 中设置。
MobCombatObservations.valid
python
self.valid公开实例属性，在 __init__、close 中设置。
MobObservationPump
python
class MobObservationPumpSDK 说明：
text
Dedicated poll task; callers own creation/cooperative stop and durable sink.
sink(event, signals) has a bounded wait; persistence fences guard_state.
Backpressure/gaps seal the projection. Cancellation-resistant sinks may finish
their original write later but can never re-enable this projection.
ready means running, NOT target bound, fresh health, or complete coverage.
Any exit invalidates evidence and awaits stream.close. Never reconnects.MobObservationPump.__init__
python
def __init__(self, stream, projection, *, sink, sink_timeout=0.5)MobObservationPump.request_stop
python
def request_stop(self)SDK 说明：
text
Fence new guards immediately; finish the admitted poll/sink before close.
Await the existing run task without cancelling it on normal shutdown.
Cancellation remains an exceptional retirement path and may seal IPC.MobObservationPump.invalidate
python
def invalidate(self)MobObservationPump.guard_state
python
def guard_state(self, *, max_age=0.5)SDK 说明：
text
Public admission view; unavailable during persistence or stopped pump.
Consumers must require guard_ready AND bound, plus their independent
freshness/identity/inventory/tick checks. ready Event alone is insufficient.MobObservationPump.run
python
async def run(self)MobObservationPump.sink_timeout
python
self.sink_timeout公开实例属性，在 __init__ 中设置。
MobObservationPump.stream
python
self.stream公开实例属性，在 __init__ 中设置。
MobObservationPump.projection
python
self.projection公开实例属性，在 __init__、run 中设置。
MobObservationPump.sink
python
self.sink公开实例属性，在 __init__ 中设置。
MobObservationPump.ready
python
self.ready公开实例属性，在 __init__ 中设置。