From 5a4b999b7d6ba1955c8d61e9fa7afc9364b0c86f Mon Sep 17 00:00:00 2001 From: Macpie Date: Thu, 10 Oct 2024 14:11:20 -0700 Subject: [PATCH] More rebase fix --- ingest/src/server_mobile.rs | 9 +++------ ingest/tests/common/mod.rs | 3 +-- 2 files changed, 4 insertions(+), 8 deletions(-) diff --git a/ingest/src/server_mobile.rs b/ingest/src/server_mobile.rs index 036946715..6081ac63d 100644 --- a/ingest/src/server_mobile.rs +++ b/ingest/src/server_mobile.rs @@ -14,13 +14,10 @@ use helium_proto::services::poc_mobile::{ CoverageObjectIngestReportV1, CoverageObjectReqV1, CoverageObjectRespV1, DataTransferSessionIngestReportV1, DataTransferSessionReqV1, DataTransferSessionRespV1, InvalidatedRadioThresholdIngestReportV1, InvalidatedRadioThresholdReportReqV1, - InvalidatedRadioThresholdReportRespV1, InvalidatedRadioThresholdReportRespV1, - PromotionRewardIngestReportV1, PromotionRewardReqV1, PromotionRewardRespV1, - RadioLocationEstimatesIngestReportV1, RadioLocationEstimatesReqV1, - RadioLocationEstimatesRespV1, RadioThresholdIngestReportV1, RadioThresholdIngestReportV1, - RadioThresholdReportReqV1, RadioThresholdReportReqV1, RadioThresholdReportRespV1, + InvalidatedRadioThresholdReportRespV1, PromotionRewardIngestReportV1, PromotionRewardReqV1, + PromotionRewardRespV1, RadioLocationEstimatesIngestReportV1, RadioLocationEstimatesReqV1, + RadioLocationEstimatesRespV1, RadioThresholdIngestReportV1, RadioThresholdReportReqV1, RadioThresholdReportRespV1, ServiceProviderBoostedRewardsBannedRadioIngestReportV1, - ServiceProviderBoostedRewardsBannedRadioIngestReportV1, ServiceProviderBoostedRewardsBannedRadioReqV1, ServiceProviderBoostedRewardsBannedRadioRespV1, SpeedtestIngestReportV1, SpeedtestReqV1, SpeedtestRespV1, SubscriberLocationIngestReportV1, SubscriberLocationReqV1, SubscriberLocationRespV1, diff --git a/ingest/tests/common/mod.rs b/ingest/tests/common/mod.rs index a25fe9fac..f36e0bb38 100644 --- a/ingest/tests/common/mod.rs +++ b/ingest/tests/common/mod.rs @@ -47,8 +47,7 @@ pub async fn setup_mobile() -> anyhow::Result<(TestClient, Trigger)> { let (sp_boosted_tx, _rx) = tokio::sync::mpsc::channel(10); let (subscriber_mapping_tx, subscriber_mapping_rx) = tokio::sync::mpsc::channel(10); let (promotion_rewards_tx, _rx) = tokio::sync::mpsc::channel(10); - let (radio_location_estimates_tx, _radio_location_estimates_rx) = - tokio::sync::mpsc::channel(10); + let (radio_location_estimates_tx, radio_location_estimates_rx) = tokio::sync::mpsc::channel(10); tokio::spawn(async move { let grpc_server = GrpcServer::new(