pub async fn init<ReadStateService, Tip>(
listen_addr: SocketAddr,
_read_state: ReadStateService,
chain_tip_change: Tip,
) -> Result<(JoinHandle<Result<(), BoxError>>, SocketAddr), BoxError>where
ReadStateService: Service<ReadRequest, Response = ReadResponse, Error = BoxError> + Clone + Send + Sync + 'static,
<ReadStateService as Service<ReadRequest>>::Future: Send,
Tip: ChainTip + Clone + Send + Sync + 'static,
Expand description
Initializes the indexer RPC server