async fn run_rpc_listener<R: Runtime>(
runtime: R,
incoming: impl Stream<Item = Result<(Stream, SocketAddr, Arc<RpcConnInfo>)>> + Unpin,
rpc_mgr: Arc<RpcMgr>,
client: Arc<TorClient<R>>,
launchable: Arc<LaunchableTorClient<R>>,
rpc_state: Arc<RpcVisibleArtiState>,
) -> Result<()>Expand description
Backend function to implement an RPC listener: runs in a loop.