Experimental async support

for now only with Curio, but trio and pure asyncio planned

Author: tshirtman

.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']
 

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/curio_example.py

@@ -0,0 +1,31 @@
+from curio import socket
+
+import curio
+
+from oscpy.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()
+
+    await osc.process()
+
+curio.run(osc_app, '0.0.0.0', 8000)

examples/thread_example.py

@@ -0,0 +1,12 @@
+from oscpy.server import OSCThreadServer
+from time import sleep
+
+osc = OSCThreadServer()
+sock = osc.listen(address='0.0.0.0', port=8000, default=True)
+
+@osc.address(b'/address')
+def callback(*values):
+    print("got values: {}".format(values))
+
+sleep(1000)
+osc.stop()