Function main

src/benchmarks/benchmarks.cpp:79–941

#endif

int main(int argc, char* argv[]) // NOLINT(bugprone-exception-escape)
{
    auto                        bench         = ankerl::nanobench::Bench{}.output(nullptr).warmup(3);
    const auto                  args          = std::span{argv, static_cast<size_t>(argc)};
    const auto                  benchmark     = find_argument("--benchmark=", args);
    const auto                  section       = find_argument("--section=", args);
    [[maybe_unused]] const auto disable_rxcpp = find_argument("--disable_rxcpp", args).has_value();
    const auto                  disable_rpp   = find_argument("--disable_rpp", args).has_value();
    const auto                  dump          = find_argument("--dump=", args);

    BENCHMARK("General")
    {
        SECTION("Subscribe empty callbacks to empty observable")
        {
            TEST_RPP([&]() {
                rpp::source::create<int>([&](auto&& observer) {
                    ankerl::nanobench::doNotOptimizeAway(observer);
                })
                    .subscribe([](int) {});
            });

            TEST_RXCPP([&]() {
                rxcpp::observable<>::create<int>([&](auto&& observer) {
                    ankerl::nanobench::doNotOptimizeAway(observer);
                })
                    .subscribe([](int) {});
            });
        }

        SECTION("Subscribe empty callbacks to empty observable via pipe operator")
        {
            TEST_RPP([&]() {
                rpp::source::create<int>([&](auto&& observer) {
                    ankerl::nanobench::doNotOptimizeAway(observer);
                })
                    | rpp::operators::subscribe([](int) {});
            });

            TEST_RXCPP([&]() {
                rxcpp::observable<>::create<int>([&](auto&& observer) {
                    ankerl::nanobench::doNotOptimizeAway(observer);
                })
                    | rxcpp::operators::subscribe<int>([](int) {});
            });
        }
    }; // BENCHMARK("General")

    BENCHMARK("Sources")
    {
        SECTION("from array of 1 - create + subscribe + immediate")
        {
            std::array<int, 1> vals{123};
            TEST_RPP([&]() {
                rpp::source::from_iterable(vals, rpp::schedulers::immediate{}).subscribe([](int v) { ankerl::nanobench::doNotOptimizeAway(v); });
            });

            TEST_RXCPP([&]() {
                rxcpp::observable<>::iterate(vals, rxcpp::identity_immediate()).subscribe([](int v) { ankerl::nanobench::doNotOptimizeAway(v); });