From 1e9f1331809994472eab1d43058c1f3b976f2afa Mon Sep 17 00:00:00 2001
From: Abdulla Abdurakhmanov <me@abdolence.dev>
Date: Wed, 1 Jan 2025 14:27:00 +0100
Subject: [PATCH] chore: Fix Arrow IPC deprecated function

---
 README.md           | 1 +
 src/arrow_format.rs | 6 +++++-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/README.md b/README.md
index a7234d4..24b7467 100644
--- a/README.md
+++ b/README.md
@@ -28,6 +28,7 @@ axum-streams = { version = "0.18", features=["json", "csv", "protobuf", "text"]
 
 | axum | axum-streams |
 |------|--------------|
+| 0.8  | v0.20+       |
 | 0.7  | v0.11+       |
 | 0.6  | v0.9-v0.10   |
 | 0.5  | 0.7          |
diff --git a/src/arrow_format.rs b/src/arrow_format.rs
index 99431b1..817925d 100644
--- a/src/arrow_format.rs
+++ b/src/arrow_format.rs
@@ -46,7 +46,11 @@ impl StreamingFormat<RecordBatch> for ArrowRecordBatchIpcStreamFormat {
             let mut writer = BytesMut::new().writer();
 
             if let Some(prepend_schema) = prepend_schema {
-                let encoded_message = ipc_data_gen.schema_to_bytes(&prepend_schema, write_options);
+                let encoded_message = ipc_data_gen.schema_to_bytes_with_dictionary_tracker(
+                    &prepend_schema,
+                    dictionary_tracker,
+                    write_options,
+                );
                 write_message(&mut writer, encoded_message, write_options)?;
             }