Method onReceive

proto/simple_protocol.cpp:109–212

}

bool Receiver::onReceive(size_t type, const void* data, size_t size)
{
    switch (type)
    {
        case FBE::simple::SimpleRequestModel::fbe_type():
        {
            // Deserialize the value from the FBE stream
            SimpleRequestModel.attach(data, size);
            assert(SimpleRequestModel.verify() && "simple::SimpleRequest validation failed!");
            [[maybe_unused]] size_t deserialized = SimpleRequestModel.deserialize(SimpleRequestValue);
            assert((deserialized > 0) && "simple::SimpleRequest deserialization failed!");

            // Log the value
            if (this->_logging)
            {
                std::string message = SimpleRequestValue.string();
                this->onReceiveLog(message);
            }

            // Call receive handler with deserialized value
            onReceive(SimpleRequestValue);
            return true;
        }
        case FBE::simple::SimpleResponseModel::fbe_type():
        {
            // Deserialize the value from the FBE stream
            SimpleResponseModel.attach(data, size);
            assert(SimpleResponseModel.verify() && "simple::SimpleResponse validation failed!");
            [[maybe_unused]] size_t deserialized = SimpleResponseModel.deserialize(SimpleResponseValue);
            assert((deserialized > 0) && "simple::SimpleResponse deserialization failed!");

            // Log the value
            if (this->_logging)
            {
                std::string message = SimpleResponseValue.string();
                this->onReceiveLog(message);
            }

            // Call receive handler with deserialized value
            onReceive(SimpleResponseValue);
            return true;
        }
        case FBE::simple::SimpleRejectModel::fbe_type():
        {
            // Deserialize the value from the FBE stream
            SimpleRejectModel.attach(data, size);
            assert(SimpleRejectModel.verify() && "simple::SimpleReject validation failed!");
            [[maybe_unused]] size_t deserialized = SimpleRejectModel.deserialize(SimpleRejectValue);
            assert((deserialized > 0) && "simple::SimpleReject deserialization failed!");

            // Log the value
            if (this->_logging)
            {
                std::string message = SimpleRejectValue.string();
                this->onReceiveLog(message);
            }

            // Call receive handler with deserialized value