mirror of https://github.com/nocturn9x/giambio.git
removed the sync_only decorator
This commit is contained in:
parent
f7fadabc5e
commit
94092a7ae7
|
@ -8,17 +8,6 @@ import socket
|
||||||
from .exceptions import GiambioError, AlreadyJoinedError
|
from .exceptions import GiambioError, AlreadyJoinedError
|
||||||
import traceback
|
import traceback
|
||||||
|
|
||||||
return_values = {} # Saves the return values from coroutines
|
|
||||||
exceptions = {} # Saves exceptions from errored coroutines
|
|
||||||
|
|
||||||
|
|
||||||
def sync_only(func):
|
|
||||||
@wraps(func)
|
|
||||||
def wrapper(*args, **kwargs):
|
|
||||||
if iscoroutine(2):
|
|
||||||
raise RuntimeError(f"Function '{func.__name__}' MUST be called from a synchronous context!")
|
|
||||||
return func(*args, **kwargs)
|
|
||||||
return wrapper
|
|
||||||
|
|
||||||
|
|
||||||
class Task:
|
class Task:
|
||||||
|
@ -54,7 +43,6 @@ class EventLoop:
|
||||||
self.running = None # This will always point to the currently running coroutine (Task object)
|
self.running = None # This will always point to the currently running coroutine (Task object)
|
||||||
self.waitlist = defaultdict(list) # Tasks that want to join
|
self.waitlist = defaultdict(list) # Tasks that want to join
|
||||||
|
|
||||||
@sync_only
|
|
||||||
def loop(self):
|
def loop(self):
|
||||||
"""Main event loop for giambio"""
|
"""Main event loop for giambio"""
|
||||||
|
|
||||||
|
@ -88,7 +76,6 @@ class EventLoop:
|
||||||
self.to_run.append(task)
|
self.to_run.append(task)
|
||||||
return task
|
return task
|
||||||
|
|
||||||
@sync_only
|
|
||||||
def start(self, coroutine: types.coroutine, *args, **kwargs):
|
def start(self, coroutine: types.coroutine, *args, **kwargs):
|
||||||
self.spawn(coroutine(*args, **kwargs))
|
self.spawn(coroutine(*args, **kwargs))
|
||||||
self.loop()
|
self.loop()
|
||||||
|
|
Loading…
Reference in New Issue