Generic ring buffer

Sources/LiveKit/Convenience/AudioProcessing.swift

@@ -117,7 +117,7 @@ public class AudioVisualizeProcessor {
 
     // MARK: - Private
 
-    private let ringBuffer = FloatRingBuffer(size: AudioVisualizeProcessor.bufferSize)
+    private let ringBuffer = RingBuffer<Float>(size: AudioVisualizeProcessor.bufferSize)
     private let processor: FFTProcessor
 
     public init(minFrequency: Float = 10,

Sources/LiveKit/Support/FloatRingBuffer.swift → Sources/LiveKit/Support/RingBuffer.swift

@@ -17,28 +17,28 @@
 import Foundation
 
 // Simple ring-buffer used for internal audio processing. Not thread-safe.
-class FloatRingBuffer {
+class RingBuffer<T: Numeric> {
     private var _isFull = false
-    private var _buffer: [Float]
+    private var _buffer: [T]
     private var _head: Int = 0
 
     init(size: Int) {
-        _buffer = Array(repeating: 0, count: size)
+        _buffer = [T](repeating: 0, count: size)
     }
 
-    func write(_ value: Float) {
+    func write(_ value: T) {
         _buffer[_head] = value
         _head = (_head + 1) % _buffer.count
         if _head == 0 { _isFull = true }
     }
 
-    func write(_ sequence: [Float]) {
+    func write(_ sequence: [T]) {
         for value in sequence {
             write(value)
         }
     }
 
-    func read() -> [Float]? {
+    func read() -> [T]? {
         guard _isFull else { return nil }
 
         if _head == 0 {