Skip to content

Commit

Permalink
cargo fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
fixxxedpoint committed Apr 19, 2024
1 parent d73f215 commit 73b9f8e
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
1 change: 0 additions & 1 deletion mock/src/dataio.rs
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,6 @@ pub struct FinalizationHandler {
}

impl FinalizationHandlerT<Data> for FinalizationHandler {

fn data_finalized(&mut self, data: Data) {
if let Err(e) = self.tx.unbounded_send(data) {
error!(target: "finalization-handler", "Error when sending data from FinalizationHandler {:?}.", e);
Expand Down
6 changes: 4 additions & 2 deletions types/src/dataio.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
use aleph_bft_crypto::NodeMap;
use async_trait::async_trait;

use crate::{Data, NodeIndex, Round, Hasher};
use crate::{Data, Hasher, NodeIndex, Round};

/// The source of data items that consensus should order.
///
Expand Down Expand Up @@ -43,7 +43,9 @@ pub struct OrderedUnit<D: Data, H: Hasher> {
pub round: Round,
}

impl<D: Data, H: Hasher, FH: FinalizationHandler<D>> FinalizationHandler<Vec<OrderedUnit<D, H>>> for FH {
impl<D: Data, H: Hasher, FH: FinalizationHandler<D>> FinalizationHandler<Vec<OrderedUnit<D, H>>>
for FH
{
fn data_finalized(&mut self, batch: Vec<OrderedUnit<D, H>>) {
for unit in batch {
if let Some(data) = unit.data {
Expand Down

0 comments on commit 73b9f8e

Please sign in to comment.