o i|@s"ddlZddlZGdddZdS)Nc@s(eZdZdZddZddZddZdS) CallbackzA callback is when synchronized call needs to call outside functions passed into it. Currently only supports non-generator functions.cCs||_||_dSN) _synchronizer_f)self synchronizerfr J/home/ubuntu/.local/lib/python3.10/site-packages/synchronicity/callback.py__init__ s zCallback.__init__cCsj|j|i|}t|r!zt}||W|S|wt|r*tdt |r3td|S)Nz"Async generators are not supportedzGenerators are not supported) rinspect iscoroutineasyncionew_event_looprun_until_completeclose isasyncgen RuntimeError isgenerator)rargskwargsresloopr r r _invokes    zCallback._invokecsF|j|}|j|}t}|d|j||IdH}|j|Sr)r_translate_outrget_event_looprun_in_executorr _translate_in)rrrrrr r r __call__s    zCallback.__call__N)__name__ __module__ __qualname____doc__r rrr r r r rs  r)rr rr r r r s