pub fn dedup_block_stream( stream: impl Stream<Item = Result<CarBlock>>, ) -> impl Stream<Item = Result<CarBlock>>