Experimental async support (asyncio/trio/curio)

.github/workflows/push.yml

@@ -5,7 +5,7 @@ jobs:
     name: base
     strategy:
       matrix:
-        python: [ '2.7', '3.5', '3.6', '3.6', '3.7']
+        python: [ '2.7', '3.6', '3.6', '3.7', '3.8', '3.9']
         # os: ['ubuntu-latest', 'windows-latest', 'macOs-latest']
         os: ['ubuntu-latest', 'windows-latest']
 
@@ -20,6 +20,9 @@ jobs:
       run: pip install -U setuptools wheel
     - name: install
       run: pip install .[dev,ci]
+    - name: install async requirements
+      if: matrix.python != '2.7'
+      run: pip install trio curio
     - name: test
       run: python -m pytest --reruns 5 tests/ --cov oscpy/ --cov-branch
     - name: coveralls

.gitignore

@@ -3,6 +3,10 @@
 *.c
 *.pyd
 *.egg-info
+*.swp
+*.swn
+.coverage
+htmlcov/
 .pytest_cache
 build
 dist

README.md

@@ -136,6 +136,29 @@ with OSCAsyncServer(port=8000) as OSC:
             print("unknown address {}".format(address))
 ```
 
+Server (curio)
+
+```python
+async def osc_app(address, port):
+    osc = OSCCurioServer(encoding='utf8')
+    osc.listen(address=address, port=port, default=True)
+
+    @osc.address("/example")
+    async def example(*values):
+        print(f"got {values} on /example")
+        await curio.sleep(4)
+        print("done sleeping")
+
+    @osc.address("/stop")
+    async def stop(*values):
+        print(f"time to leave!")
+        await osc.stop()
+
+    await osc.process()
+
+curio.run(osc_app, '0.0.0.0', 8000)
+```
+
 Client
 
 ```python

examples/asyncio_example.py

@@ -0,0 +1,33 @@
+import asyncio
+
+from oscpy.server.asyncio_server import OSCAsyncioServer
+
+
+async def osc_app(address, port):
+    osc = OSCAsyncioServer(encoding='utf8')
+    osc.listen(address=address, port=port, default=True)
+    sock2 = osc.listen(address=address, port=port + 1)
+
+    @osc.address("/example")
+    async def example(*values):
+        print(f"got {values} on /example")
+        await asyncio.sleep(4)
+        print("done sleeping")
+
+    @osc.address("/test")
+    async def test(*values):
+        print(f"got {values} on /test")
+        await asyncio.sleep(4)
+        print("done sleeping")
+
+    @osc.address("/stop", sock=sock2)
+    async def stop(*values):
+        print(f"time to leave!")
+        osc.terminate_server()
+
+    print(sock2.getsockname())
+    asyncio.get_event_loop().create_task(osc.process())
+    await osc.join_server()
+
+
+asyncio.run(osc_app('localhost', 8000))

examples/curio_example.py

@@ -0,0 +1,29 @@
+import curio
+
+from oscpy.server.curio_server import OSCCurioServer
+
+
+async def osc_app(address, port):
+    osc = OSCCurioServer(encoding='utf8')
+    osc.listen(address=address, port=port, default=True)
+
+    @osc.address("/example")
+    async def example(*values):
+        print(f"got {values} on /example")
+        await curio.sleep(4)
+        print("done sleeping")
+
+    @osc.address("/test")
+    async def test(*values):
+        print(f"got {values} on /test")
+        await curio.sleep(4)
+        print("done sleeping")
+
+    @osc.address("/stop")
+    async def stop(*values):
+        print(f"time to leave!")
+        await osc.stop_all()
+
+    await osc.process()
+
+curio.run(osc_app, '0.0.0.0', 8000)

examples/thread_example.py

@@ -0,0 +1,22 @@
+import sys
+from time import sleep
+
+from oscpy.server import OSCThreadServer
+
+osc = OSCThreadServer(encoding='utf8')
+sock = osc.listen(address='0.0.0.0', port=8000, default=True)
+
+@osc.address('/address')
+def callback(*values):
+    print("got values: {}".format(values))
+
+
+@osc.address('/stop')
+def callback(*values):
+    print("time to leave")
+    osc.stop_all()
+    osc.terminate_server()
+
+
+# wait until the server exits
+osc.join_server()

examples/trio_example.py

@@ -0,0 +1,34 @@
+import trio
+
+from oscpy.server.trio_server import OSCTrioServer
+
+
+async def osc_app(address, port):
+    osc = OSCTrioServer(encoding='utf8')
+    await osc.listen(address=address, port=port, default=True)
+
+    @osc.address("/example")
+    async def example(*values):
+        print(f"got {values} on /example")
+        await trio.sleep(4)
+        print("done sleeping")
+
+    @osc.address("/test")
+    async def test(*values):
+        print(f"got {values} on /test")
+        await trio.sleep(4)
+        print("done sleeping")
+
+    @osc.address("/stop")
+    async def stop(*values):
+        print(f"time to leave!")
+        await osc.stop_all()
+
+    @osc.address("/info")
+    async def info():
+        address, port = osc.getaddress()
+        print(address, port)
+
+    await osc.process()
+
+trio.run(osc_app, '0.0.0.0', 8000)