c++ - 使用 rxcpp 和 cpr 的计时器事件（获取请求）

Question

我正在尝试做一个每秒向api发出请求并获得答案并将其返回给我并将其添加到缓冲区的东西

对于查询我使用 cpr，对于其他所有我使用 rxcpp

我不知道怎么写，但这是我的尝试（希望你能帮助我）

#include <cpr/cpr.h>

#include "rxcpp/rx.hpp"
#include "rxcpp/rx-test.hpp"

namespace Rx {
    using namespace rxcpp;
    using namespace rxcpp::sources;
    using namespace rxcpp::operators;
    using namespace rxcpp::util;
}
using namespace Rx;

#include <iostream>

int main() {
    
    std::vector<std::string> allData;
    
    auto getData = [](std::string URL) {
        return observable<>::defer([=]() {


            return cpr::Get(cpr::Url{ URL }) |
                map([](cpr::Response r) {
                return r.text;
                    }) |
                repeat() |
                timer<>(std::chrono::seconds(1));
            }); // do I need subscribe here?
    };

    // auto newData = getData("http//example.com//api")
    // allData.push(newData)

    return 0;
}