INNER CODE UNIT · Python
set
permitio/fastapi_websocket_rpc · fastapi_websocket_rpc/rpc_channel.py:62
def set(self):
"""
Signal completion of request with received response
"""
self._event.set()
def wait(self):
"""
Wait on the internal event - triggered on response
"""
return self._event.wait()
class RpcProxy:
"""
Helper class
provide a __call__ interface for an RPC method over a given channel
"""