pub(crate) async fn await_receive_claimed( client: &Client, operation_id: OperationId, ) -> Result<()>