commit 8867721271643a40962b45ee57420f8b85ec871b
author aaronyujiaze <aaronyujiaze@google.com> Thu May 26 20:53:00 2022
committer Copybara-Service <copybara-worker@google.com> Thu May 26 20:55:18 2022
tree a59fc9d339cdcd4f844cd28ab7a0dd264c39864a
parent 500f67c85ec5bf22758a239128fbbe11242f6f26

Add reset for std::promise

std::promise needs to be reinitialized for each async operation after std::future is returned
PiperOrigin-RevId: 451236518

internal/platform/implementation/windows/ble_medium.cc

diff --git a/internal/platform/implementation/windows/ble_medium.cc b/internal/platform/implementation/windows/ble_medium.cc
index 477f428..55f49e8 100644
--- a/internal/platform/implementation/windows/ble_medium.cc
+++ b/internal/platform/implementation/windows/ble_medium.cc
@@ -14,6 +14,7 @@
 
 #include "internal/platform/implementation/windows/ble_medium.h"
 
+#include <future>  // NOLINT
 #include <string>
 
 #include "absl/synchronization/mutex.h"
@@ -97,6 +98,8 @@
   publisher_token_ =
       publisher_.StatusChanged({this, &BleMedium::PublisherHandler});
 
+  publisher_started_promise_ = std::promise<PublisherState>();
+
   std::future<PublisherState> publisher_state_future =
       publisher_started_promise_.get_future();
 
@@ -110,6 +113,8 @@
 
   NEARBY_LOGS(INFO) << "Windows Ble StopAdvertising: service_id=" << service_id;
 
+  publisher_stopped_promise_ = std::promise<PublisherState>();
+
   std::future<PublisherState> publisher_state_future =
       publisher_stopped_promise_.get_future();
 
@@ -132,6 +137,8 @@
   advertisement_received_token_ =
       watcher_.Received({this, &BleMedium::AdvertisementReceivedHandler});
 
+  watcher_started_promise_ = std::promise<WatcherState>();
+
   std::future<WatcherState> watcher_state_future =
       watcher_started_promise_.get_future();
 
@@ -154,6 +161,8 @@
 
   NEARBY_LOGS(INFO) << "Windows Ble StopScanning: service_id=" << service_id;
 
+  watcher_stopped_promise_ = std::promise<WatcherState>();
+
   std::future<WatcherState> watcher_state_future =
       watcher_stopped_promise_.get_future();