Close recv stream after receiving block

diff --git a/src/main.rs b/src/main.rs
index 8b49782a29b3cf220af245010611a1a3b2419be4..ae0bb5b833ce37510b099072bd97068ac7bac532 100644 (file)
--- a/src/main.rs
+++ b/src/main.rs
@@ -156,6 +156,7 @@ pub fn scan_node(scan_time: Instant, node: SocketAddr, manual: bool) {
                                                return future::err(());
                                        }
                                        check_set_flag!(recvd_block, "block");
+                                       return future::err(());
                                },
                                _ => {},
                        }