Moved test decorator to separate file

ably/executer/decorator.py

@@ -1,39 +1,6 @@
 import functools
 from asyncio import events
 
-from ably.executer.eventloop import AppEventLoop
-
-
-def force_sync(fn):
-    '''
-    Forces async function to be used as sync function.
-    Blocks execution of caller till result is returned.
-    This decorator should only be used on async methods/coroutines.
-    '''
-    import asyncio
-
-    @functools.wraps(fn)
-    def wrapper(*args, **kwargs):
-        caller_eventloop = None
-        try:
-            caller_eventloop: events = asyncio.get_running_loop()
-        except Exception:
-            pass
-        app_loop: events = AppEventLoop.get_global().loop
-
-        res = fn(*args, **kwargs)
-        if asyncio.iscoroutine(res):
-            # Handle calls from app eventloop on the same loop, return awaitable
-            if caller_eventloop is not None and caller_eventloop == app_loop:
-                return res
-
-            # Block the caller till result is returned
-            future = asyncio.run_coroutine_threadsafe(res, app_loop)
-            return future.result()
-        return res
-
-    return wrapper
-
 
 def optional_sync(fn):
     '''

test/ably/decorator.py

@@ -0,0 +1,35 @@
+import functools
+from asyncio import events
+
+from ably.executer.eventloop import AppEventLoop
+
+
+def force_sync(fn):
+    '''
+    Forces async function to be used as sync function.
+    Blocks execution of caller till result is returned.
+    This decorator should only be used on async methods/coroutines.
+    '''
+    import asyncio
+
+    @functools.wraps(fn)
+    def wrapper(*args, **kwargs):
+        caller_eventloop = None
+        try:
+            caller_eventloop: events = asyncio.get_running_loop()
+        except Exception:
+            pass
+        app_loop: events = AppEventLoop.get_global().loop
+
+        res = fn(*args, **kwargs)
+        if asyncio.iscoroutine(res):
+            # Handle calls from app eventloop on the same loop, return awaitable
+            if caller_eventloop is not None and caller_eventloop == app_loop:
+                return res
+
+            # Block the caller till result is returned
+            future = asyncio.run_coroutine_threadsafe(res, app_loop)
+            return future.result()
+        return res
+
+    return wrapper

test/ably/testapp.py

@@ -2,12 +2,12 @@
 import os
 import logging
 
-from ably.executer.decorator import force_sync
 from ably.rest.rest import AblyRest
 from ably.types.capability import Capability
 from ably.types.options import Options
 from ably.util.exceptions import AblyException
 from ably.realtime.realtime import AblyRealtime
+from test.ably.decorator import force_sync
 
 log = logging.getLogger(__name__)