on_message_matching()

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

Creates an Event coroutine that fires only when a predicate matches.

Parameters

source	Shared ownership of the NetworkSource
predicate	Returns true for messages that should trigger the callback
callback	Invoked with each matching message

Returns

Event coroutine suitable for EventManager::add_event()

auto task = Kriya::on_message_matching(src,
    [](const Core::NetworkMessage& m) { return m.data.size() == 4; },
    [](const Core::NetworkMessage& msg) { });

Definition at line 46 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 (predicate(msg)) {
            callback(msg);
        }
    }
}

Referenced by MayaFlux::on_network_message_matching().

Here is the caller graph for this function: