Replace asyncio.iscoroutinefunction with inspect.iscoroutinefunction

Author: coretl

src/p4p/client/asyncio.py

@@ -3,6 +3,7 @@
 _log = logging.getLogger(__name__)
 
 import asyncio
+import inspect
 
 from functools import partial, wraps
 
@@ -63,7 +64,7 @@ async def exec():
                 await dostuff(ctxt, timeout=5)
     """
     def decorate(fn):
-        assert asyncio.iscoroutinefunction(fn), "Place @timesout before @coroutine"
+        assert inspect.iscoroutinefunction(fn), "Place @timesout before @coroutine"
 
         @wraps(fn)
         async def wrapper(*args, timeout=deftimeout, **kws):
@@ -291,7 +292,7 @@ def monitor(self, name, cb, request=None, notify_disconnect=False) -> "Subscript
         * A p4p.Value (Subject to :py:ref:`unwrap`)
         * A sub-class of Exception (Disconnected , RemoteError, or Cancelled)
         """
-        assert asyncio.iscoroutinefunction(cb), "monitor callback must be coroutine"
+        assert inspect.iscoroutinefunction(cb), "monitor callback must be coroutine"
         R = Subscription(name, cb, notify_disconnect=notify_disconnect)
         cb = partial(get_running_loop().call_soon_threadsafe, R._E.set)
 

src/p4p/test/asynciotest.py

@@ -12,6 +12,7 @@
 from .utils import RefTestCase
 
 import asyncio
+import inspect
 
 from ..client.asyncio import Context, Disconnected, timesout
 from ..server.asyncio import SharedPV
@@ -31,7 +32,7 @@ class AsyncMeta(type):
     """
     def __new__(klass, name, bases, classdict):
         for name, mem in classdict.items():
-            if name.startswith('test') and asyncio.iscoroutinefunction(mem):
+            if name.startswith('test') and inspect.iscoroutinefunction(mem):
                 @wraps(mem)
                 def wrapper(self, mem=mem):
                     self.loop.run_until_complete(asyncio.wait_for(mem(self), self.timeout))