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();