From d5fb493aa4011e6df36864b5957e2886d0b559c7 Mon Sep 17 00:00:00 2001
From: carllin <wumu727@gmail.com>
Date: Thu, 15 Aug 2019 15:17:46 -0700
Subject: [PATCH] Change recv to try_recv (#5533)

---
 core/src/snapshot_package.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/snapshot_package.rs b/core/src/snapshot_package.rs
index 85ded3dd9..61496b510 100644
--- a/core/src/snapshot_package.rs
+++ b/core/src/snapshot_package.rs
@@ -131,7 +131,7 @@ impl SnapshotPackagerService {
     fn run(snapshot_receiver: &SnapshotPackageReceiver) -> Result<()> {
         let mut snapshot_package = snapshot_receiver.recv_timeout(Duration::from_secs(1))?;
         // Only package the latest
-        while let Ok(new_snapshot_package) = snapshot_receiver.recv() {
+        while let Ok(new_snapshot_package) = snapshot_receiver.try_recv() {
             snapshot_package = new_snapshot_package;
         }
         Self::package_snapshots(&snapshot_package)?;