Struct GraphObserveOne 

pub struct GraphObserveOne { /* private fields */ }

Single-node observe handle. subscribe taps downstream messages from the observed node (same payload shape as a direct graphrefly_core::Core::subscribe, including the [Start, Data?] handshake when a cache is present per R1.2.3 / R1.3.5.a).

up methods send tier-2 / tier-4 messages upstream (PAUSE / RESUME / INVALIDATE) — the up(messages) API per canonical §3.6.2 specialized to the supported message kinds. Tier-3 / tier-5 / tier-6 messages have no upstream-injection semantics.

Implementations

impl GraphObserveOne

pub fn node_id(&self) -> NodeId

The observed NodeId.

pub fn subscribe(&self, sink: Sink) -> Subscription

Subscribe a sink. Drop the returned Subscription to detach.

pub fn pause(&self, lock: LockId) -> Result<(), PauseError>

Send [PAUSE, lock] upstream (per canonical §3.6.2 up(...)).

pub fn resume(&self, lock: LockId) -> Result<Option<ResumeReport>, PauseError>

Send [RESUME, lock] upstream.

pub fn invalidate(&self)

Send [INVALIDATE] upstream.