nexusrpc.handler._core.BaseServiceCollectionHandler

class documentation

class BaseServiceCollectionHandler(AbstractHandler, ABC):

A Nexus handler, managing a collection of Nexus service handlers.

Operation requests are delegated to a ServiceHandler based on the service name in the operation context.

Method	`__init__`	Initialize a `Handler` instance from user service handler instances.
Instance Variable	`executor`	Undocumented
Instance Variable	`service_handlers`	Undocumented
Method	`_get_service_handler`	Return a service handler, given the service name.
Method	`_register_service_handlers`	Undocumented

Inherited from AbstractHandler:

Method	`cancel_operation`	Handle a Cancel Operation request.
Method	`start_operation`	Undocumented

def __init__(self, user_service_handlers: Sequence[Any], executor: concurrent.futures.Executor | None = None): ¶

overridden in nexusrpc.handler.Handler

Initialize a Handler instance from user service handler instances.

The user service handler instances must have been decorated with the @nexusrpc.handler.service_handler decorator.

Parameters
user_service_handlers:`Sequence[Any]`	A sequence of user service handlers.
executor:`concurrent.futures.Executor \| None`	A concurrent.futures.Executor in which to run non-`async def` operation handlers.

executor = ¶

Undocumented

service_handlers = ¶

Undocumented

def _get_service_handler(self, service_name: str) -> ServiceHandler: ¶

Return a service handler, given the service name.

def _register_service_handlers(self, user_service_handlers: Sequence[Any]) -> Mapping[str, ServiceHandler]: ¶

Undocumented