From a9531c86a433c8b7ae1f77ff0266c27c39eca7f4 Mon Sep 17 00:00:00 2001
From: jacqueline <me@jacqueline.id.au>
Date: Fri, 10 Mar 2023 11:28:33 +1100
Subject: mostly single task pipeline

---
 src/audio/include/audio_task.hpp | 31 ++++++++++++++++++++++++++-----
 1 file changed, 26 insertions(+), 5 deletions(-)

(limited to 'src/audio/include/audio_task.hpp')

diff --git a/src/audio/include/audio_task.hpp b/src/audio/include/audio_task.hpp
index df70ebaa..8db99850 100644
--- a/src/audio/include/audio_task.hpp
+++ b/src/audio/include/audio_task.hpp
@@ -6,17 +6,38 @@
 
 #include "audio_element.hpp"
 #include "freertos/portmacro.h"
+#include "pipeline.hpp"
 
 namespace audio {
 
+namespace task {
 struct AudioTaskArgs {
-  std::shared_ptr<IAudioElement>& element;
+  Pipeline* pipeline;
+  QueueHandle_t input;
 };
 
-auto StartAudioTask(const std::string& name,
-                    std::optional<BaseType_t> core_id,
-                    std::shared_ptr<IAudioElement> element) -> void;
+extern "C" void AudioTaskMain(void* args);
 
-void AudioTaskMain(void* args);
+enum Command { PLAY, PAUSE, QUIT };
+
+class Handle {
+ public:
+  explicit Handle(QueueHandle_t input);
+  ~Handle();
+
+  auto SetStreamInfo() -> void;
+  auto Play() -> void;
+  auto Pause() -> void;
+  auto Quit() -> void;
+
+  auto OutputBuffer() -> StreamBufferHandle_t;
+
+ private:
+  QueueHandle_t input;
+};
+
+auto Start(Pipeline* pipeline) -> Handle*;
+
+}  // namespace task
 
 }  // namespace audio
-- 
cgit v1.2.3