From 3947452e391b1f1fc3933b28ce97d86e3b555d84 Mon Sep 17 00:00:00 2001 From: Dimitri Staessens Date: Tue, 30 Jun 2026 18:56:30 +0200 Subject: examples: Update oecho samples Update the oecho / oecho_set examples to the new flow and QoS API. --- examples/oecho.py | 26 ++++++++++++++++++++------ 1 file changed, 20 insertions(+), 6 deletions(-) (limited to 'examples/oecho.py') 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() -- cgit v1.2.3