pub(crate) async fn wait_invoice_payment_updates(
prefix: &str,
gateway_name: &str,
operation_id: OperationId,
event_sender: &UnboundedSender<MetricEvent>,
pay_invoice_time: SystemTime,
updates: &mut (impl Stream<Item = LnReceiveState> + Unpin),
) -> Result<()>