Struct SubscriptionState 

pub struct SubscriptionState {
    pub manager: Arc<SubscriptionManager>,
    pub lifecycle: Arc<dyn SubscriptionLifecycle>,
    pub max_subscriptions_per_connection: Option<u32>,
    pub remote_subscription_fields: Arc<HashMap<String, String>>,
}

State for subscription WebSocket handler.

Fields

manager: Arc<SubscriptionManager>

Subscription manager.

lifecycle: Arc<dyn SubscriptionLifecycle>

Lifecycle hooks.

max_subscriptions_per_connection: Option<u32>

Maximum subscriptions per connection (None = unlimited).

remote_subscription_fields: Arc<HashMap<String, String>>

Subscription fields owned by remote subgraphs.

Maps root subscription field name to the subgraph WebSocket URL. Empty when federation is disabled or no remote subscription fields are declared.

Implementations

impl SubscriptionState

pub fn new(manager: Arc<SubscriptionManager>) -> Self

Create new subscription state.

pub fn with_lifecycle(self, lifecycle: Arc<dyn SubscriptionLifecycle>) -> Self

Set lifecycle hooks.

pub const fn with_max_subscriptions(self, max: Option<u32>) -> Self

Set maximum subscriptions per connection.

pub fn with_remote_subscription_fields( self, fields: HashMap<String, String>, ) -> Self

Set remote subscription fields (federation passthrough).

Maps subscription field names to the owning subgraph’s WebSocket URL.

Trait Implementations

impl Clone for SubscriptionState

fn clone(&self) -> SubscriptionState

Returns a duplicate of the value.

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

Performs copy-assignment from source.