Sulkta-OSS/pallas
3
0
Fork 0
Code Issues 1 Pull requests 4 Projects Releases Packages Wiki Activity Actions

feat: Make blockfetch observer mutable (#86)

Browse source
This commit is contained in:
Santiago Carmuega 2022-04-08 18:52:38 -03:00 • committed by GitHub
parent 40e16326c6
commit 07531693a7
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
examples/block-download/src/main.rs
View file

@ -16,7 +16,7 @@ use std::net::TcpStream;
struct BlockPrinter; struct BlockPrinter;
impl Observer for BlockPrinter { impl Observer for BlockPrinter {
fn on_block_received(&self, body: Vec<u8>) -> Result<(), Box<dyn std::error::Error>> { fn on_block_received(&mut self, body: Vec<u8>) -> Result<(), Box<dyn std::error::Error>> {
println!("{}", hex::encode(&body)); println!("{}", hex::encode(&body));
println!("----------"); println!("----------");
Ok(()) Ok(())

6
pallas-miniprotocols/src/blockfetch/mod.rs
View file

@ -88,7 +88,7 @@ impl<'b> Decode<'b> for Message {
} }
pub trait Observer { pub trait Observer {
fn on_block_received(&self, body: Vec<u8>) -> Result<(), Box<dyn std::error::Error>> { fn on_block_received(&mut self, body: Vec<u8>) -> Result<(), Box<dyn std::error::Error>> {
log::debug!("block received, sice: {}", body.len()); log::debug!("block received, sice: {}", body.len());
Ok(()) Ok(())
} }
@ -148,7 +148,7 @@ where
}) })
} }
fn on_block(self, body: Vec<u8>) -> Transition<Self> { fn on_block(mut self, body: Vec<u8>) -> Transition<Self> {
log::debug!("received block body, size {}", body.len()); log::debug!("received block body, size {}", body.len());
self.observer.on_block_received(body)?; self.observer.on_block_received(body)?;
@ -287,7 +287,7 @@ where
}) })
} }
fn on_block(self, body: Vec<u8>) -> Transition<Self> { fn on_block(mut self, body: Vec<u8>) -> Transition<Self> {
log::debug!("received block body, size {}", body.len()); log::debug!("received block body, size {}", body.len());
self.observer.on_block_received(body)?; self.observer.on_block_received(body)?;