diff --git a/utils/p4runtime_lib/switch.py b/utils/p4runtime_lib/switch.py
index 1b92b09..be330c3 100644
--- a/utils/p4runtime_lib/switch.py
+++ b/utils/p4runtime_lib/switch.py
@@ -65,6 +65,8 @@ class SwitchConnection(object):
             print "P4Runtime MasterArbitrationUpdate: ", request
         else:
             self.requests_stream.put(request)
+            for item in self.stream_msg_resp:
+                return item # just one
 
     def SetForwardingPipelineConfig(self, p4info, dry_run=False, **kwargs):
         device_config = self.buildDeviceConfig(**kwargs)