fmt

Author: bcherry

livekit-rtc/livekit/rtc/participant.py

@@ -293,20 +293,22 @@ async def perform_rpc(
     def register_rpc_method(
         self,
         method_name: str,
-        handler: Optional[Callable[[RpcInvocationData], Union[Awaitable[str], str]]] = None,
+        handler: Optional[
+            Callable[[RpcInvocationData], Union[Awaitable[str], str]]
+        ] = None,
     ) -> Union[None, Callable]:
         """
         Establishes the participant as a receiver for calls of the specified RPC method.
         Can be used either as a decorator or a regular method.
-        
+
         The handler will recieve one argument of type `RpcInvocationData` and should return a string response which will be forwarded back to the caller.
-        
+
         The handler may be synchronous or asynchronous.
 
         If unable to respond within `response_timeout`, the caller will hang up and receive an error on their side.
 
         You may raise errors of type `RpcError` in the handler, and they will be forwarded to the caller.
-        
+
         Other errors raised in your handler will be caught and forwarded to the caller as "1500 Application Error".
 
         Args:
@@ -322,7 +324,7 @@ def register_rpc_method(
             async def greet_handler(data: RpcInvocationData) -> str:
                 print(f"Received greeting from {data.caller_identity}: {data.payload}")
                 return f"Hello, {data.caller_identity}!"
-                
+
             # As a regular method:
             async def greet_handler(data: RpcInvocationData) -> str:
                 print(f"Received greeting from {data.caller_identity}: {data.payload}")
@@ -382,7 +384,9 @@ async def _handle_rpc_method_invocation(
         else:
             try:
                 if asyncio.iscoroutinefunction(handler):
-                    async_handler = cast(Callable[[RpcInvocationData], Awaitable[str]], handler)
+                    async_handler = cast(
+                        Callable[[RpcInvocationData], Awaitable[str]], handler
+                    )
 
                     async def run_handler():
                         try:

livekit-rtc/livekit/rtc/rpc.py

@@ -41,7 +41,7 @@ class RpcError(Exception):
 
     Instances of this type, when thrown in a method handler, will have their `message`
     serialized and sent across the wire. The caller will receive an equivalent error on the other side.
-    
+
     Built-in errors are included (codes 1001-1999) but developers may use the code, message, and data fields to create their own errors.
     """
 
@@ -83,7 +83,7 @@ def __init__(
         Creates an error object with the given code and message, plus an optional data payload.
 
         If thrown in an RPC method handler, the error will be sent back to the caller.
-        
+
         Args:
             code (int): Your error code (Error codes 1001-1999 are reserved for built-in errors)
             message (str): A readable error message.
@@ -97,7 +97,7 @@ def __init__(
     @property
     def code(self) -> int:
         """Error code value. Codes 1001-1999 are reserved for built-in errors (see RpcError.ErrorCode for their meanings)."""
-        return self._code   
+        return self._code
 
     @property
     def message(self) -> str: