Endpoint(pipe: Pipe)
@endpoint.route(route: str)
Register route handler
@endpoint.default
Register default handler
def send(
route: str,
data: Any,
callback: Optional[Callable] = None
) -> str
Send data to route with optional callback
def send_response(
data: Any,
info: dict
) -> None
Send response to request
def start(block: bool = True) -> None
Start endpoint
def stop() -> None
Stop endpoint
Global request object with properties:
meta
: Raw bytes datajson
: JSON parsed datastring
: String decoded dataResponse(route: str, data: Any)
Response object for route handlers