nexusrpc.handler._core._EnsuredAwaitableOperationHandler

class documentation

class _EnsuredAwaitableOperationHandler(MiddlewareSafeOperationHandler):

Constructor: _EnsuredAwaitableOperationHandler(executor, op_handler)

An AwaitableOperationHandler that wraps an OperationHandler and uses an _Executor to ensure that the start and cancel methods are awaitable.

Method	`__init__`	Undocumented
Async Method	`cancel`	Cancel an operation using the wrapped `OperationHandler`.
Async Method	`start`	Start the operation using the wrapped `OperationHandler`.
Instance Variable	`_executor`	Undocumented
Instance Variable	`_op_handler`	Undocumented

def __init__(self, executor: _Executor | None, op_handler: OperationHandler[Any, Any]): ¶

Undocumented

async def cancel(self, ctx: CancelOperationContext, token: str): ¶

overrides nexusrpc.handler.MiddlewareSafeOperationHandler.cancel

Cancel an operation using the wrapped OperationHandler.

async def start(self, ctx: StartOperationContext, input: Any) -> StartOperationResultSync[Any] | StartOperationResultAsync: ¶

overrides nexusrpc.handler.MiddlewareSafeOperationHandler.start

Start the operation using the wrapped OperationHandler.

_executor = ¶

Undocumented

_op_handler = ¶

Undocumented