diff options
| -rw-r--r-- | ryu/lib/rpc.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/ryu/lib/rpc.py b/ryu/lib/rpc.py index 3aa476dd..010f0a80 100644 --- a/ryu/lib/rpc.py +++ b/ryu/lib/rpc.py @@ -304,3 +304,11 @@ class Client(object): raise EOFError("EOF") self._process_input_notification() self._process_input_request() + + def peek_notification(self): + while True: + rlist, _wlist = self._endpoint.selectable() + rlist, _wlist, _xlist = select.select(rlist, [], [], 0) + if not rlist: + break + self.receive_notification() |