From dd95bc315538c2506c853b3848f9408b84ebd665 Mon Sep 17 00:00:00 2001
From: Arya <aryasolhi@gmail.com>
Date: Thu, 15 Feb 2024 19:53:28 -0500
Subject: [PATCH] moves `Results` request above `SubscribeResults` request to
 avoid duplicate results.

---
 zebra-grpc/src/server.rs | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/zebra-grpc/src/server.rs b/zebra-grpc/src/server.rs
index 26a40f7bad5..5ab0e05fd8b 100644
--- a/zebra-grpc/src/server.rs
+++ b/zebra-grpc/src/server.rs
@@ -79,15 +79,11 @@ where
 
         let keys: Vec<_> = keys.into_iter().map(|(key, _start_at)| key).collect();
 
-        let ScanServiceResponse::SubscribeResults(mut results_receiver) = self
+        let ScanServiceResponse::Results(results) = self
             .scan_service
             .clone()
             .ready()
-            .and_then(|service| {
-                service.call(ScanServiceRequest::SubscribeResults(
-                    keys.iter().cloned().collect(),
-                ))
-            })
+            .and_then(|service| service.call(ScanServiceRequest::Results(keys.clone())))
             .await
             .map_err(|err| Status::unknown(format!("scan service returned error: {err}")))?
         else {
@@ -96,11 +92,15 @@ where
             ));
         };
 
-        let ScanServiceResponse::Results(results) = self
+        let ScanServiceResponse::SubscribeResults(mut results_receiver) = self
             .scan_service
             .clone()
             .ready()
-            .and_then(|service| service.call(ScanServiceRequest::Results(keys.clone())))
+            .and_then(|service| {
+                service.call(ScanServiceRequest::SubscribeResults(
+                    keys.iter().cloned().collect(),
+                ))
+            })
             .await
             .map_err(|err| Status::unknown(format!("scan service returned error: {err}")))?
         else {