diff --git a/p2p/src/protocol/sync.rs b/p2p/src/protocol/sync.rs
index d69fab57..fc92f9ab 100644
--- a/p2p/src/protocol/sync.rs
+++ b/p2p/src/protocol/sync.rs
@@ -46,7 +46,7 @@ pub trait OutboundSyncConnection : Send + Sync {
 	fn send_transaction(&self, message: &types::Tx);
 	fn send_block(&self, message: &types::Block, id: u32, is_final: bool);
 	fn send_headers(&self, message: &types::Headers, id: u32, is_final: bool);
-	fn send_mempool(&self, message: &types::MemPool, id: u32, is_final: bool);
+	fn send_mempool(&self, message: &types::MemPool);
 	fn send_filterload(&self, message: &types::FilterLoad);
 	fn send_filteradd(&self, message: &types::FilterAdd);
 	fn send_filterclear(&self, message: &types::FilterClear);
@@ -106,8 +106,8 @@ impl OutboundSyncConnection for OutboundSync {
 		self.context.send_response(message, id, is_final);
 	}
 
-	fn send_mempool(&self, message: &types::MemPool, id: u32, is_final: bool) {
-		self.context.send_response(message, id, is_final);
+	fn send_mempool(&self, message: &types::MemPool) {
+		self.context.send_request(message);
 	}
 
 	fn send_filterload(&self, message: &types::FilterLoad) {
diff --git a/sync/src/local_node.rs b/sync/src/local_node.rs
index ad2dc8b1..a51d9836 100644
--- a/sync/src/local_node.rs
+++ b/sync/src/local_node.rs
@@ -257,7 +257,7 @@ mod tests {
 		fn send_transaction(&self, _message: &types::Tx) {}
 		fn send_block(&self, _message: &types::Block, _id: u32, _is_final: bool) {}
 		fn send_headers(&self, _message: &types::Headers, _id: u32, _is_final: bool) {}
-		fn send_mempool(&self, _message: &types::MemPool, _id: u32, _is_final: bool) {}
+		fn send_mempool(&self, _message: &types::MemPool) {}
 		fn send_filterload(&self, _message: &types::FilterLoad) {}
 		fn send_filteradd(&self, _message: &types::FilterAdd) {}
 		fn send_filterclear(&self, _message: &types::FilterClear) {}
diff --git a/sync/src/synchronization_client.rs b/sync/src/synchronization_client.rs
index ec0a8ed3..da470606 100644
--- a/sync/src/synchronization_client.rs
+++ b/sync/src/synchronization_client.rs
@@ -495,11 +495,7 @@ impl<T> Client for SynchronizationClient<T> where T: TaskExecutor {
 
 				// relay block to our peers
 				if self.state.is_saturated() {
-					let mut executor = self.executor.lock();
-					for peer in self.peers.all_peers() {
-						// TODO: Task::BroadcastBlock instead of cloning
-						executor.execute(Task::SendBlock(peer, block.clone()));
-					}
+					// TODO: Task::BroadcastBlock
 				}
 
 				// deal with block transactions