Experimental async support

Extract code to be reused into an OSCBaseServer class
move OSCThreadServer to its own module, inheriting from OSCBaseServer
Create an OSCCurioServer and an OSCThreadServer to support async usage.

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

.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/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,15 @@
+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))
+
+
+# exit after 1000 seconds
+sleep(1000)
+osc.stop()

examples/trio_example.py

@@ -0,0 +1,29 @@
+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()
+
+    await osc.process()
+
+trio.run(osc_app, '0.0.0.0', 8000)