on_message()

MAYAFLUX_API Vruta::Event MayaFlux::Kriya::on_message	(	std::shared_ptr< Vruta::NetworkSource >	source,
		std::function< void(const Core::NetworkMessage &)>	callback
	)

Creates an Event coroutine that fires on every message received by a source.

Parameters

source	Shared ownership of the NetworkSource; lifetime is tied to the coroutine frame
callback	Invoked with each received message

Returns

Event coroutine suitable for EventManager::add_event()

auto src = std::make_shared<Vruta::NetworkSource>(
    Core::EndpointInfo{ .transport = Core::NetworkTransport::UDP, .local_port = 8000 });
auto task = Kriya::on_message(src, [](const Core::NetworkMessage& msg) { });

Definition at line 10 of file NetworkEvents.cpp.

{
    auto& promise = co_await GetEventPromise { source };
 
    while (true) {
        if (promise.should_terminate) {
            break;
        }
 
        auto msg = co_await source->next_message();
        callback(msg);
    }
}

Referenced by MayaFlux::on_network_message().

Here is the caller graph for this function: