on_message_from()

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

Creates an Event coroutine that fires only for messages from a specific sender.

Parameters

source	Shared ownership of the NetworkSource
sender_address	IP address string matched against NetworkMessage::sender_address
callback	Invoked with each matching message

Returns

Event coroutine suitable for EventManager::add_event()

auto task = Kriya::on_message_from(src, "192.168.1.10",
    [](const Core::NetworkMessage& msg) { });

Definition at line 26 of file NetworkEvents.cpp.

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

Referenced by MayaFlux::on_network_message_from().

Here is the caller graph for this function: