Enum DeclaredSubscriptionShape 

pub enum DeclaredSubscriptionShape {
    BufferedRaw,
    BufferedRawSafety,
}

Which of the executor’s registration entry points a DECLARED subscription lowers to.

One variant per lowering the declarative registrar can choose. Exhaustive: a new lowering is a new variant, which breaks in_place_capable at compile time and the registrar at its gate.

Variants

BufferedRaw

Node::create_generic_subscription_with_qos → Executor::register_subscription_buffered_raw_on.

BufferedRawSafety

A .safety() declaration: Node::create_generic_subscription_with_integrity → Executor::register_subscription_buffered_raw_safety_on.

Implementations

impl DeclaredSubscriptionShape

pub const fn of_declaration(safety: bool) -> Self

Classify a declaration.

safety is the declaration’s .safety() flag as the runtime will see it: a build whose safety-e2e capability is off ignores the flag and registers the basic path, so its caller masks the flag to false before asking. That mask has exactly one home on the caller’s side, for the same reason this classifier has one here.

pub const fn in_place_capable(self) -> bool

Can a registration of this shape dispatch out of the backend’s own receive slot?

The definition, not a copy of one. Each entry point writes this call into its SubscriptionRequest, so the answer a probe states and the answer the executor acts on are the same expression.

The two shapes differ, and the reason each has its answer is worth a sentence:

• BufferedRaw — true (issue 1340). Its callback is FnMut(&[u8]), borrowed bytes and nothing else, which is exactly what process_raw_in_place hands over. It was false while its arena entry was believed shared with add_arena_subscription_callback; that caller never reaches open_subscription, so the in-place arm could be local to the one entry point. A true here is a claim the build PRICES: the probe states in_place for every declared non-safety subscription, and on an in-place backend that endpoint reserves no receive region.
• BufferedRawSafety — false. process_raw_in_place has no validating form: an integrity-checked sample must be verified before the callback sees it, and the borrowed slot offers nowhere to put the verdict. Not a limit anyone plans to lift by flipping this.

Trait Implementations

impl Clone for DeclaredSubscriptionShape

fn clone(&self) -> DeclaredSubscriptionShape

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for DeclaredSubscriptionShape

impl Debug for DeclaredSubscriptionShape

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for DeclaredSubscriptionShape

impl PartialEq for DeclaredSubscriptionShape

fn eq(&self, other: &DeclaredSubscriptionShape) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for DeclaredSubscriptionShape