dbus_environment.cpp (b1ff1f65c422b51ffe48837b3a89d2b736a441e0) dbus_environment.cpp (f763c9e3bbe0f86a4a41e7bb0dc70bffde0af9b2)
1#include "dbus_environment.hpp"
2
3#include <future>
4#include <thread>
5
6DbusEnvironment::~DbusEnvironment()
7{
8 teardown();

--- 58 unchanged lines hidden (view full) ---

67}
68
69bool DbusEnvironment::waitForFuture(std::string_view name,
70 std::chrono::milliseconds timeout)
71{
72 return waitForFuture(getFuture(name), timeout);
73}
74
1#include "dbus_environment.hpp"
2
3#include <future>
4#include <thread>
5
6DbusEnvironment::~DbusEnvironment()
7{
8 teardown();

--- 58 unchanged lines hidden (view full) ---

67}
68
69bool DbusEnvironment::waitForFuture(std::string_view name,
70 std::chrono::milliseconds timeout)
71{
72 return waitForFuture(getFuture(name), timeout);
73}
74
75bool DbusEnvironment::waitForFutures(std::string_view name,
76 std::chrono::milliseconds timeout)
77{
78 auto& data = futures[std::string(name)];
79 auto ret = waitForFutures(
80 std::move(data), true, [](auto sum, auto val) { return sum && val; },
81 timeout);
82 data = std::vector<std::future<bool>>{};
83 return ret;
84}
85
75std::future<bool> DbusEnvironment::getFuture(std::string_view name)
76{
77 auto& data = futures[std::string(name)];
78 auto it = data.begin();
79
80 if (it != data.end())
81 {
82 auto result = std::move(*it);

--- 35 unchanged lines hidden --- 		86std::future<bool> DbusEnvironment::getFuture(std::string_view name)
87{
88 auto& data = futures[std::string(name)];
89 auto it = data.begin();
90
91 if (it != data.end())
92 {
93 auto result = std::move(*it);

--- 35 unchanged lines hidden ---