Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Actor that manages all active WebSocket subscriptions.

Each subscription is identified by a hex-encoded string ID and backed by a bounded Sender<String> that delivers serialised notification JSON to the corresponding WebSocket write-loop.

Implementations

impl SubscriptionManager

pub fn spawn() -> ActorRef<SubscriptionManager>

Spawn the actor and return a handle.

Trait Implementations

impl Actor for SubscriptionManager

Protocol

When started, ActorRef<SubscriptionManager> implements:

• SubscriptionManagerProtocol

See the protocol trait docs for the full API.

fn started(&mut self, _ctx: &Context<Self>) -> impl Future<Output = ()> + Send

fn stopped(&mut self, _ctx: &Context<Self>) -> impl Future<Output = ()> + Send

impl Default for SubscriptionManager

fn default() -> SubscriptionManager

Returns the “default value” for a type.

impl Handler<NewHead> for SubscriptionManager

async fn handle(&mut self, msg: NewHead, ctx: &Context<Self>)

impl Handler<Subscribe> for SubscriptionManager

async fn handle( &mut self, msg: Subscribe, ctx: &Context<Self>, ) -> Option<String>

impl Handler<Unsubscribe> for SubscriptionManager

async fn handle(&mut self, msg: Unsubscribe, ctx: &Context<Self>) -> bool