From 61c91b3cdb2c9dd655f3adf0f461f5cefb3b2e9b Mon Sep 17 00:00:00 2001
From: jacqueline <me@jacqueline.id.au>
Date: Fri, 10 Feb 2023 15:32:21 +1100
Subject: Mostly working pipeline, including proper EOF signalling

---
 src/audio/fatfs_audio_input.cpp | 10 ++++++++++
 1 file changed, 10 insertions(+)

(limited to 'src/audio/fatfs_audio_input.cpp')

diff --git a/src/audio/fatfs_audio_input.cpp b/src/audio/fatfs_audio_input.cpp
index 08f39347..8990bf4f 100644
--- a/src/audio/fatfs_audio_input.cpp
+++ b/src/audio/fatfs_audio_input.cpp
@@ -69,6 +69,16 @@ auto FatfsAudioInput::ProcessChunk(const cpp::span<std::byte>& chunk)
   return cpp::fail(UNSUPPORTED_STREAM);
 }
 
+auto FatfsAudioInput::ProcessEndOfStream() -> void {
+  if (is_file_open_) {
+      f_close(&current_file_);
+      is_file_open_ = false;
+      SendOrBufferEvent(
+          std::unique_ptr<StreamEvent>(
+            StreamEvent::CreateEndOfStream(input_events_)));
+  }
+}
+
 auto FatfsAudioInput::Process() -> cpp::result<void, AudioProcessingError> {
   if (is_file_open_) {
     auto dest_event = std::unique_ptr<StreamEvent>(
-- 
cgit v1.2.3