From 220b9e2ca73afaaeff72c53482e21bd282430c61 Mon Sep 17 00:00:00 2001
From: YAMAMOTO Takashi <yamamoto@valinux.co.jp>
Date: Thu, 28 Nov 2013 14:30:04 +0900
Subject: add rpc.Client.peek_notification

Signed-off-by: YAMAMOTO Takashi <yamamoto@valinux.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
---
 ryu/lib/rpc.py | 8 ++++++++
 1 file changed, 8 insertions(+)

(limited to 'ryu/lib/rpc.py')

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()
-- 
cgit v1.2.3