Struct OwnedCore 

pub struct OwnedCore { /* private fields */ }

Owns a Core, tracks the subscriptions opened through it, and tears them down on the owner thread in Drop. Construct with OwnedCore::new (fresh Core) or OwnedCore::with_core (adopt a Core the caller already built).

Implementations

impl OwnedCore

pub fn new(binding: Arc<dyn BindingBoundary>) -> Self

Build a fresh Core wired to binding and own it.

pub fn with_core(core: Core) -> Self

Adopt a Core the caller already constructed.

pub fn core(&self) -> &Core

Borrow the owned dispatcher. This is the D231 owner-side &Core — pass it explicitly into every Core-touching op (graph, structures, storage, producer build). Never store or clone it.

pub fn binding(&self) -> Arc<dyn BindingBoundary>

The binding this Core was wired with.

pub fn track_subscribe(&self, node_id: NodeId, sink: Sink) -> SubscriptionId

Subscribe a sink and track it for owner-thread teardown on drop. Returns the SubscriptionId for an explicit early Self::unsubscribe (D246 rule 3 — owner-invoked, synchronous; no RAII below the binding).

pub fn track_subscribe_topology( &self, sink: TopologySink, ) -> TopologySubscriptionId

Subscribe a topology sink and track it for teardown on drop.

pub fn unsubscribe(&self, node_id: NodeId, sub_id: SubscriptionId)

Explicit early unsubscribe (owner-invoked, synchronous — D225/ D241). Idempotent: a later Drop won’t double-unsubscribe a detached id (and core unsubscribe is itself idempotent on monotonic never-recycled ids).

pub fn unsubscribe_topology(&self, id: TopologySubscriptionId)

Explicit early topology unsubscribe (owner-invoked, synchronous).

Trait Implementations

impl Drop for OwnedCore

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.