examples: Update oecho samplesHEAD0.24.0master

Update the oecho / oecho_set examples to the new flow and QoS API.

1 files changed, 20 insertions, 6 deletions

diff --git a/examples/oecho.py b/examples/oecho.py
index d3fccfe..4bf3e05 100755
--- a/examples/oecho.py
+++ b/examples/oecho.py
@@ -35,28 +35,42 @@
 # ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
 # OF THE POSSIBILITY OF SUCH DAMAGE.
 
-from ouroboros.dev import *
+"""A simple echo client/server example using Ouroboros flows."""
+
+# Standalone demo; intentionally duplicates oecho_set.py.
+# pylint: disable=duplicate-code
+
+from __future__ import annotations
+
 import argparse
 
+from ouroboros.dev import flow_accept, flow_alloc
+
 
-def client():
+def client() -> None:
+    """Send a message and print the echo reply."""
     with flow_alloc("oecho") as f:
         f.writeline("Hello, PyOuroboros!")
         print(f.readline())
 
 
-def server():
+def server() -> None:
+    """Accept flows and echo back received messages."""
     print("Starting the server.")
     while True:
         with flow_accept() as f:
             print("New flow.")
             line = f.readline()
-            print("Message from client is " + line)
+            print(f"Message from client is {line}")
             f.writeline(line)
 
 
 if __name__ == "__main__":
     parser = argparse.ArgumentParser(description='A simple echo client/server')
-    parser.add_argument('-l', '--listen', help='run as a server', action='store_true')
+    parser.add_argument('-l', '--listen', help='run as a server',
+                        action='store_true')
     args = parser.parse_args()
-    server() if args.listen is True else client()
+    if args.listen:
+        server()
+    else:
+        client()