wip

1 files changed, 46 insertions, 0 deletions

diff --git a/tests/wqueue2.py b/tests/wqueue2.py
new file mode 100755
index 0000000..d53da36
--- /dev/null
+++ b/tests/wqueue2.py
@@ -0,0 +1,46 @@
+#!/usr/bin/python3.5
+
+import asyncio
+import os
+
+async def test():
+    print('sleeping...')
+    await asyncio.sleep(3)
+    print('slept')
+
+
+async def manage_client(reader, writer):
+    print('manage_client created')
+    print('called on connection only ?')
+    await asyncio.sleep(1)
+    print('after sleep1 in server()')
+    while True:
+        line = await reader.readline()
+        if not line:
+            break
+        print('line', line)
+        writer.write(line)
+
+
+def main():
+    print('getting event loop')
+    loop = asyncio.get_event_loop()
+    print('got event loop')
+    # loop.call_soon(test)
+    try:
+        os.unlink('server_sock')
+        print('creating coro...')
+        coro = asyncio.start_unix_server(manage_client, path='server_sock')
+        print('coro created')
+        loop.run_until_complete(coro)
+        print('coro returned')
+        # loop.run_until_complete(test())
+        loop.run_forever()
+    except KeyboardInterrupt:
+        pass
+    print('loop closed')
+    loop.close()
+
+
+if __name__ == '__main__':
+    main()