Struct SubscriptionState

Defined in File subscription_manager.hpp

Struct Documentation

struct SubscriptionState

Per-subscription synchronization state for SSE stream coordination. The SSE stream thread waits on the CV; update/remove operations notify it.

Public Members

CyclicSubscriptionInfo info

std::mutex mtx

std::condition_variable cv

std::atomic<bool> active = {true}

bool notified = {false}: Set by notify(), cleared by wait_for_update()