Pre-connect improvements (#699)

Author: pblazej

Sources/LiveKit/Core/PreConnectAudioBuffer.swift

@@ -146,25 +146,30 @@ public final class PreConnectAudioBuffer: NSObject, Sendable, Loggable {
             throw LiveKitError(.invalidState, message: "Audio stream is nil")
         }
 
-        let audioData = try await audioStream.collect()
-        guard audioData.count > 1024 else {
-            throw LiveKitError(.unknown, message: "Audio data size too small, nothing to send")
-        }
-
         let streamOptions = StreamByteOptions(
             topic: topic,
             attributes: [
                 "sampleRate": "\(recorder.sampleRate)",
                 "channels": "\(recorder.channels)",
                 "trackId": recorder.track.sid?.stringValue ?? "",
             ],
-            destinationIdentities: agents,
-            totalSize: audioData.count
+            destinationIdentities: agents
         )
         let writer = try await room.localParticipant.streamBytes(options: streamOptions)
-        try await writer.write(audioData)
+
+        var sentSize = 0
+        for await chunk in audioStream {
+            do {
+                try await writer.write(chunk)
+            } catch {
+                try await writer.close(reason: error.localizedDescription)
+                throw error
+            }
+            sentSize += chunk.count
+        }
         try await writer.close()
-        log("Sent \(recorder.duration(audioData.count))s = \(audioData.count / 1024)KB of audio data to \(agents.count) agent(s) \(agents)", .info)
+
+        log("Sent \(recorder.duration(sentSize))s = \(sentSize / 1024)KB of audio data to \(agents.count) agent(s) \(agents)", .info)
     }
 }
 

Sources/LiveKit/Core/Room+PreConnect.swift

@@ -45,7 +45,7 @@ public extension Room {
     /// - See: ``PreConnectAudioBuffer``
     /// - Important: Call ``AudioManager/setRecordingAlwaysPreparedMode(_:)`` during app launch sequence to request microphone permissions early.
     ///
-    func withPreConnectAudio<T>(timeout: TimeInterval = 10,
+    func withPreConnectAudio<T>(timeout: TimeInterval = PreConnectAudioBuffer.Constants.timeout,
                                 _ operation: @Sendable @escaping () async throws -> T,
                                 onError: PreConnectAudioBuffer.OnError? = nil) async throws -> T
     {
@@ -61,7 +61,7 @@ public extension Room {
     }
 
     @available(*, deprecated, message: "Use withPreConnectAudio instead")
-    func startCapturingBeforeConnecting(timeout: TimeInterval = 10) async throws {
+    func startCapturingBeforeConnecting(timeout: TimeInterval = PreConnectAudioBuffer.Constants.timeout) async throws {
         try await preConnectBuffer.startRecording(timeout: timeout)
     }
 }