adapt to asyncgui 0.6.2, and publish asynckivy 0.6.3

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "asynckivy"
-version = "0.6.2"
+version = "0.6.3"
 description = "Async library for Kivy"
 authors = ["Nattōsai Mitō <flow4re2c@gmail.com>"]
 license = "MIT"

src/asynckivy/_event.py

@@ -2,7 +2,7 @@
 
 import typing as T
 from functools import partial
-from asyncgui import IBox
+from asyncgui import AsyncEvent
 
 
 async def event(event_dispatcher, event_name, *, filter=None, stop_dispatching=False) -> T.Awaitable[tuple]:
@@ -40,16 +40,16 @@ async def event(event_dispatcher, event_name, *, filter=None, stop_dispatching=F
       It only works for events not for properties.
       See :ref:`kivys-event-system` for details.
     '''
-    box = IBox()
-    bind_id = event_dispatcher.fbind(event_name, partial(_callback, filter, box, stop_dispatching))
+    ev = AsyncEvent()
+    bind_id = event_dispatcher.fbind(event_name, partial(_callback, filter, ev, stop_dispatching))
     assert bind_id  # check if binding succeeded
     try:
-        return (await box.get())[0]
+        return (await ev.wait())[0]
     finally:
         event_dispatcher.unbind_uid(event_name, bind_id)
 
 
-def _callback(filter, box, stop_dispatching, *args, **kwargs):
+def _callback(filter, ev, stop_dispatching, *args, **kwargs):
     if (filter is None) or filter(*args, **kwargs):
-        box.put(*args)
+        ev.fire(*args)
         return stop_dispatching

src/asynckivy/_threading.py

@@ -27,7 +27,7 @@ async def run_in_thread(func, *, daemon=None) -> T.Awaitable:
 
     See :ref:`io-in-asynckivy` for details.
     '''
-    box = asyncgui.IBox()
+    box = asyncgui.AsyncBox()
     Thread(
         name='asynckivy.run_in_thread',
         target=_wrapper, daemon=daemon, args=(func, box, ),
@@ -51,7 +51,7 @@ async def run_in_executor(executor: ThreadPoolExecutor, func) -> T.Awaitable:
 
     See :ref:`io-in-asynckivy` for details.
     '''
-    box = asyncgui.IBox()
+    box = asyncgui.AsyncBox()
     future = executor.submit(_wrapper, func, box)
     try:
         ret, exc = (await box.get())[0]