aboutsummaryrefslogtreecommitdiff
path: root/examples/oecho.py
diff options
context:
space:
mode:
Diffstat (limited to 'examples/oecho.py')
-rwxr-xr-xexamples/oecho.py26
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()