AsyncSinkRunner

class savant.client.runner.sink.AsyncSinkRunner(socket, log_provider, idle_timeout, module_health_check_url, module_health_check_timeout, module_health_check_interval, receive_timeout=1000, receive_hwm=50, source_id=None, source_id_prefix=None)

Receives messages from ZeroMQ socket asynchronously.