o i @s|ddlmZddlmZddlmZmZmZddlm Z ddl m Z m Z m Z mZmZddlmZGdd d eeefZd S) ) annotations)Callable)InputT OperationInfoOutputT)is_async_callable)CancelOperationContextFetchOperationInfoContextFetchOperationResultContextStartOperationContextStartOperationResultSync)OperationHandlerc@sBeZdZdZdddZdd d ZdddZd ddZd!ddZdS)"SyncOperationHandlera An :py:class:`nexusrpc.handler.OperationHandler` that is limited to responding synchronously. The name 'SyncOperationHandler' means that it responds synchronously, in the sense that the start method delivers the final operation result as its return value, rather than returning an operation token representing an in-progress operation. This version of the class uses `def` methods. For the async version, see :py:class:`nexusrpc.handler.SyncOperationHandler`. start2Callable[[StartOperationContext, InputT], OutputT]cCsHt|r t|d||_|jr t|jdd}r"|j|_dSdSdS)Nz is an `async def` method. SyncOperationHandler must be initialized with a `def` method. To use `async def` methods, use nexusrpc.handler.SyncOperationHandler.__func__)r RuntimeError_start__doc__getattrr)selfr start_funcr^/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/nexusrpc/handler/_syncio.py__init__#s zSyncOperationHandler.__init__ctxr inputrreturn!StartOperationResultSync[OutputT]cCst|||S)zP Start the operation and return its final result synchronously. )r r)rrrrrrr/szSyncOperationHandler.startr tokenstrrcCtd)NzJCannot fetch operation info for an operation that responded synchronously.NotImplementedErrorrrr rrr fetch_info7zSyncOperationHandler.fetch_infor rcCr")NzECannot fetch the result of an operation that responded synchronously.r#r%rrr fetch_result<r'z!SyncOperationHandler.fetch_resultrNonecCr")Nz>An operation that responded synchronously cannot be cancelled.r#r%rrrcancelAr'zSyncOperationHandler.cancelN)rr)rr rrrr)rr r r!rr)rr r r!rr)rrr r!rr)) __name__ __module__ __qualname__rrrr&r(r*rrrrrs  rN) __future__rtypingrnexusrpc._commonrrrnexusrpc._utilrnexusrpc.handler._commonrr r r r _operation_handlerrrrrrrs