如何在rxcpp中处理请求/响应流

#include <rxcpp/rx.hpp>

using namespace rxcpp;

// 创建Observable对象表示请求流
observable<std::string> createRequestStream() {
    return observable<std::string>::create([](subscriber<std::string> s) {
        // 发送请求
        s.on_next("request1");
        s.on_next("request2");
        s.on_next("request3");
        s.on_completed();
    });
}

int main() {
    // 创建请求流
    auto requestStream = createRequestStream();

    // 处理请求流
    auto responseStream = requestStream
        .map([](const std::string& request) {
            // 处理请求，返回响应
            return "response: " + request;
        });

    // 订阅响应流
    responseStream.subscribe([](const std::string& response) {
        // 处理响应
        std::cout << response << std::endl;
    });

    return 0;
}