Skip to content

Commit

Permalink
rename test variables
Browse files Browse the repository at this point in the history
  • Loading branch information
darunrs committed Jun 14, 2024
1 parent c92fd81 commit be06911
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions block-streamer/src/bitmap_processor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -352,10 +352,9 @@ mod tests {
.times(1)
.returning(move |_, _| Ok(mock_query_result.clone()));

let block_height_stream = BitmapProcessor::new(mock_graphql_client, mock_s3_client);
let bitmap_processor = BitmapProcessor::new(mock_graphql_client, mock_s3_client);

let stream =
block_height_stream.stream_matching_block_heights(0, "someone.near".to_owned());
let stream = bitmap_processor.stream_matching_block_heights(0, "someone.near".to_owned());
tokio::pin!(stream);
let mut result_heights = vec![];
while let Some(Ok(height)) = stream.next().await {
Expand Down Expand Up @@ -423,10 +422,10 @@ mod tests {
wildcard_query_result(105, "wA=="),
])
});
let block_height_stream = BitmapProcessor::new(mock_graphql_client, mock_s3_client);
let bitmap_processor = BitmapProcessor::new(mock_graphql_client, mock_s3_client);

let stream =
block_height_stream.stream_matching_block_heights(0, "*.someone.near".to_string());
bitmap_processor.stream_matching_block_heights(0, "*.someone.near".to_string());
tokio::pin!(stream);
let mut result_heights = vec![];
while let Some(Ok(height)) = stream.next().await {
Expand Down

0 comments on commit be06911

Please sign in to comment.