diff options
Diffstat (limited to 'examples/oecho.py')
| -rwxr-xr-x | examples/oecho.py | 26 |
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() |
