Events, Methods, and Fields

// === SKELETON (Provider) side ===
// Send event to all current subscribers
skel.Temperature.Send(25.3f);

// Optionally allocate a sample in-place (zero-copy)
auto sample = skel.Temperature.Allocate();
*sample = ReadSensor();
skel.Temperature.Send(std::move(sample));

// Know how many subscribers are active
skel.Temperature.SetSubscriptionStateChangeHandler(
    [](ara::com::SubscriptionState state) {
        if (state == ara::com::SubscriptionState::kSubscribed)
            LogInfo() << "Subscriber count changed";
    });

// === PROXY (Consumer) side ===
proxy.Temperature.Subscribe(10); // maxSampleCount = 10
proxy.Temperature.SetReceiveHandler([&] {
    proxy.Temperature.GetNewSamples([](auto s) { Use(*s); }, 5);
});

// === SKELETON side: handler returns Future ===
skel.Calibrate.SetHandler(
    [](float offset) -> ara::core::Future<CalibrateOutput> {
        ara::core::Promise<CalibrateOutput> promise;
        if (std::abs(offset) > 1.0f) {
            // Return application error
            promise.SetError(CalibrationError::kOffsetOutOfRange);
        } else {
            ApplyOffset(offset);
            promise.set_value(CalibrateOutput{true});
        }
        return promise.get_future();
    });

// === SKELETON side ===
// Must call Update() before OfferService() to set initial value
skel.Status.Update(SensorStatus::kOperational);
skel.OfferService();

// Update value later — notifies all subscribed consumers
skel.Status.Update(SensorStatus::kDegraded);

// === PROXY side ===
// Get current value (calls Getter method on provider)
auto fut = proxy.Status.Get();
SensorStatus status = fut.get().Value();

// Subscribe to change notifications
proxy.Status.SetReceiveHandler([&] {
    proxy.Status.GetNewSamples([](auto s) {
        HandleStatusChange(*s);
    }, 5);
});
proxy.Status.Subscribe(5);