signal()

template<typename T >

void MayaFlux::Vruta::BroadcastSource< T >::signal ( const T &  value )

inline

Deliver a value to the waiting coroutine, or store it as pending.

Atomically takes the waiter slot. If a waiter is present, delivers directly and resumes. Otherwise stores the value for the next await_ready() or post-registration check.

Safe to call from any thread.

Parameters

value

Value to deliver.

Definition at line 63 of file BroadcastSource.hpp.

    {
        auto* w = m_waiter.exchange(nullptr, std::memory_order_acq_rel);
        if (w) {
            w->deliver(value);
        } else {
            m_pending_value = value;
            m_pending_flag.store(true, std::memory_order_release);
        }
    }

References MayaFlux::Vruta::BroadcastSource< T >::m_pending_flag, MayaFlux::Vruta::BroadcastSource< T >::m_pending_value, and MayaFlux::Vruta::BroadcastSource< T >::m_waiter.