From 4f377e67108621e40cd7cd8dc9b4ecc43f723218 Mon Sep 17 00:00:00 2001 From: Greg Fitzgerald Date: Fri, 25 May 2018 17:06:10 -0600 Subject: [PATCH] Generalize serialize_responses --- src/request_stage.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/request_stage.rs b/src/request_stage.rs index 8b4e0db09..63344ede7 100644 --- a/src/request_stage.rs +++ b/src/request_stage.rs @@ -4,9 +4,10 @@ use bincode::{deserialize, serialize}; use packet; use packet::SharedPackets; use rayon::prelude::*; -use request::{Request, Response}; +use request::Request; use request_processor::RequestProcessor; use result::Result; +use serde::Serialize; use std::collections::VecDeque; use std::net::SocketAddr; use std::sync::Arc; @@ -36,8 +37,8 @@ impl RequestStage { } /// Split Request list into verified transactions and the rest - fn serialize_response( - resp: Response, + fn serialize_response( + resp: T, rsp_addr: SocketAddr, blob_recycler: &packet::BlobRecycler, ) -> Result { @@ -53,8 +54,8 @@ impl RequestStage { Ok(blob) } - fn serialize_responses( - rsps: Vec<(Response, SocketAddr)>, + fn serialize_responses( + rsps: Vec<(T, SocketAddr)>, blob_recycler: &packet::BlobRecycler, ) -> Result> { let mut blobs = VecDeque::new();