From 2b4d544feba939fbc67c0a298d397af9a151928c Mon Sep 17 00:00:00 2001
From: Alex Coats <alexandcoats@gmail.com>
Date: Wed, 8 Nov 2023 11:19:36 -0500
Subject: [PATCH] rename

---
 src/bin/inx-chronicle/inx/mod.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/bin/inx-chronicle/inx/mod.rs b/src/bin/inx-chronicle/inx/mod.rs
index d24ed0664..0908d55fc 100644
--- a/src/bin/inx-chronicle/inx/mod.rs
+++ b/src/bin/inx-chronicle/inx/mod.rs
@@ -275,7 +275,7 @@ impl InxWorker {
         tracing::Span::current().record("created", slot.ledger_updates().created_outputs().len());
         tracing::Span::current().record("consumed", slot.ledger_updates().consumed_outputs().len());
 
-        self.handle_cone_stream(&slot).await?;
+        self.handle_accepted_blocks(&slot).await?;
         self.db
             .collection::<ProtocolUpdateCollection>()
             .upsert_protocol_parameters(
@@ -309,10 +309,10 @@ impl InxWorker {
     }
 
     #[instrument(skip_all, err, level = "trace")]
-    async fn handle_cone_stream<'a>(&mut self, slot: &Slot<'a, Inx>) -> Result<()> {
-        let cone_stream = slot.accepted_block_stream().await?;
+    async fn handle_accepted_blocks<'a>(&mut self, slot: &Slot<'a, Inx>) -> Result<()> {
+        let blocks_stream = slot.accepted_block_stream().await?;
 
-        let mut tasks = cone_stream
+        let mut tasks = blocks_stream
             .try_chunks(INSERT_BATCH_SIZE)
             .map_err(|e| e.1)
             .try_fold(JoinSet::new(), |mut tasks, batch| async {