temporalio.worker._nexus._NexusOperationHandlerForInterceptor

class documentation

class _NexusOperationHandlerForInterceptor(nexusrpc.handler.MiddlewareSafeOperationHandler): (source)

Constructor: _NexusOperationHandlerForInterceptor(next_interceptor)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Async Method cancel Undocumented
Async Method start Undocumented
Instance Variable _next_interceptor Undocumented
def __init__(self, next_interceptor: NexusOperationInboundInterceptor): (source)

Undocumented

async def cancel(self, ctx: nexusrpc.handler.CancelOperationContext, token: str): (source)

Undocumented

async def start(self, ctx: nexusrpc.handler.StartOperationContext, input: Any) -> nexusrpc.handler.StartOperationResultSync[Any] | nexusrpc.handler.StartOperationResultAsync: (source)

Undocumented

_next_interceptor = (source)

Undocumented