recactor sanic server

this greatly simplifies the underlying implementation
by avoiding any reliance on inheritance

Author: rmorshea

scripts/live_docs.py

@@ -40,6 +40,7 @@ def new_builder():
         server = PerClientStateServer(main.component, {"cors": True})
         _running_idom_servers.append(server)
         server.run_in_thread("127.0.0.1", 5555, debug=True)
+        server.wait_until_started()
         old_builder()
 
     return new_builder

src/idom/core/dispatcher.py

@@ -42,8 +42,8 @@ async def dispatch_single_view(
             task_group.start_soon(_single_incoming_loop, layout, recv)
 
 
+SharedViewDispatcher = Callable[[SendCoroutine, RecvCoroutine], Awaitable[None]]
 _SharedViewDispatcherFuture = Callable[[SendCoroutine, RecvCoroutine], "Future[None]"]
-_SharedViewDispatcherCoro = Callable[[SendCoroutine, RecvCoroutine], Awaitable[None]]
 
 
 @asynccontextmanager
@@ -93,8 +93,8 @@ def dispatch_shared_view_soon(
 
 def ensure_shared_view_dispatcher_future(
     layout: Layout,
-) -> Tuple[Future[None], _SharedViewDispatcherCoro]:
-    dispatcher_future: Future[_SharedViewDispatcherCoro] = Future()
+) -> Tuple[Future[None], SharedViewDispatcher]:
+    dispatcher_future: Future[SharedViewDispatcher] = Future()
 
     async def dispatch_shared_view_forever() -> None:
         with layout:
@@ -121,7 +121,7 @@ async def dispatch(send: SendCoroutine, recv: RecvCoroutine) -> None:
 
 async def _make_shared_view_dispatcher(
     layout: Layout,
-) -> Tuple[_SharedViewDispatcherCoro, Ref[Any], WeakSet[Queue[LayoutUpdate]]]:
+) -> Tuple[SharedViewDispatcher, Ref[Any], WeakSet[Queue[LayoutUpdate]]]:
     initial_update = await layout.render()
     model_state = Ref(initial_update.apply_to({}))
 

src/idom/server/prefab.py

@@ -67,6 +67,7 @@ def run(
 
     run_server = server.run if not daemon else server.run_in_thread
     run_server(host, port, **(run_kwargs or {}))  # type: ignore
+    server.wait_until_started()
 
     return server
 

src/idom/server/proto.py

@@ -7,7 +7,7 @@
 
 try:
     from typing import Protocol
-except ImportError:
+except ImportError:  # pragma: no cover
     from typing_extensions import Protocol  # type: ignore