feat: implemented all layers of the feature

implemented clear and deque methods for AudioBufferQueueSourceNode
ensuring thread safety through mutex buffer lock

Author: poneciak57

packages/react-native-audio-api/common/cpp/audioapi/HostObjects/AudioBufferQueueSourceNodeHostObject.h

@@ -42,6 +42,27 @@ class AudioBufferQueueSourceNodeHostObject
 
         return jsi::Value::undefined();
     }
+
+    JSI_HOST_FUNCTION(dequeueBuffer) {
+        auto audioBufferQueueSourceNode =
+                std::static_pointer_cast<AudioBufferQueueSourceNode>(node_);
+
+        auto audioBufferHostObject =
+                args[0].getObject(runtime).asHostObject<AudioBufferHostObject>(runtime);
+
+        audioBufferQueueSourceNode->dequeueBuffer(audioBufferHostObject->audioBuffer_);
+
+        return jsi::Value::undefined();
+    }
+
+    JSI_HOST_FUNCTION(clearBuffers) {
+        auto audioBufferQueueSourceNode =
+                std::static_pointer_cast<AudioBufferQueueSourceNode>(node_);
+
+        audioBufferQueueSourceNode->clearBuffers();
+
+        return jsi::Value::undefined();
+    }
 };
 
 } // namespace audioapi

packages/react-native-audio-api/common/cpp/audioapi/core/sources/AudioBufferQueueSourceNode.cpp

@@ -44,6 +44,37 @@ void AudioBufferQueueSourceNode::enqueueBuffer(
   isLastBuffer_ = isLastBuffer;
 }
 
+void AudioBufferQueueSourceNode::dequeueBuffer(
+    const std::shared_ptr<AudioBuffer> &buffer) {
+  auto locker = Locker(getBufferLock());
+  if (buffers_.empty()) {
+    return;
+  }
+
+  if (buffers_.front() == buffer) {
+    buffers_.pop();
+    vReadIndex_ = 0.0;
+    return;
+  }
+
+  // If the buffer is not at the front, we need to remove it from the queue.
+  // And keep vReadIndex_ at the same position.
+  std::queue<std::shared_ptr<AudioBuffer>> newQueue;
+  while (!buffers_.empty()) {
+    if (buffers_.front() != buffer) {
+      newQueue.push(buffers_.front());
+    }
+    buffers_.pop();
+  }
+  std::swap(buffers_, newQueue);
+}
+
+void AudioBufferQueueSourceNode::clearBuffers() {
+  auto locker = Locker(getBufferLock());
+  buffers_ = {};
+  vReadIndex_ = 0.0;
+}
+
 void AudioBufferQueueSourceNode::disable() {
   if (isPaused_) {
     playbackState_ = PlaybackState::UNSCHEDULED;

packages/react-native-audio-api/common/cpp/audioapi/core/sources/AudioBufferQueueSourceNode.h

@@ -24,6 +24,9 @@ class AudioBufferQueueSourceNode : public AudioBufferBaseSourceNode {
     void pause();
 
     void enqueueBuffer(const std::shared_ptr<AudioBuffer> &buffer, bool isLastBuffer);
+    void dequeueBuffer(const std::shared_ptr<AudioBuffer> &buffer);
+    void clearBuffers();
+
     void disable() override;
 
  protected:

packages/react-native-audio-api/src/core/AudioBufferQueueSourceNode.ts

@@ -14,6 +14,14 @@ export default class AudioBufferQueueSourceNode extends AudioBufferBaseSourceNod
     );
   }
 
+  public dequeueBuffer(buffer: AudioBuffer): void {
+    (this.node as IAudioBufferQueueSourceNode).dequeueBuffer(buffer.buffer);
+  }
+
+  public clearBuffers(): void {
+    (this.node as IAudioBufferQueueSourceNode).clearBuffers();
+  }
+
   public override start(when: number = 0, offset?: number): void {
     if (when < 0) {
       throw new RangeError(

packages/react-native-audio-api/src/interfaces.ts

@@ -135,6 +135,8 @@ export interface IAudioBufferSourceNode extends IAudioBufferBaseSourceNode {
 export interface IAudioBufferQueueSourceNode
   extends IAudioBufferBaseSourceNode {
   enqueueBuffer: (audioBuffer: IAudioBuffer, isLastBuffer: boolean) => void;
+  dequeueBuffer: (audioBuffer: IAudioBuffer) => void;
+  clearBuffers: () => void;
   pause: () => void;
 }