rest_app

rest_app.app = <fastapi.applications.FastAPI object>: APP Startup

rest_app.health_check()[source]

async rest_app.shutdown_event()[source]

async rest_app.start_listening_endpoint(streams: List[str], current_user=Depends(check_token_validity))[source]

async rest_app.startup_event()[source]

async rest_app.stop_listening_endpoint(task_key: str, current_user=Depends(check_token_validity))[source]