Move Conversation connection properties and start helpers next to related code.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: renal128

Sources/ElevenLabs/Internal/Conversation/Conversation.swift

@@ -44,6 +44,12 @@ final class Conversation: ObservableObject {
     let agentObserverRegistry = AudioObserverRegistry()
     let micObserverRegistry = AudioObserverRegistry()
 
+    private let dependencyProvider: any ConversationDependencyProvider
+    private var activeConnectionManager: (any ConnectionManaging)?
+    private var activeWebRTCConnectionManager: (any WebRTCConnectionManaging)? {
+        activeConnectionManager as? any WebRTCConnectionManaging
+    }
+
     /// Internal LiveKit tracks used to attach ``ConversationAudioObserver``s.
     private var inputTrack: (any AudioTrackProtocol)? {
         activeWebRTCConnectionManager?.inputTrack
@@ -281,47 +287,6 @@ final class Conversation: ObservableObject {
 
     // MARK: - Private
 
-    private let dependencyProvider: any ConversationDependencyProvider
-    private var activeConnectionManager: (any ConnectionManaging)?
-    private var activeWebRTCConnectionManager: (any WebRTCConnectionManaging)? {
-        activeConnectionManager as? any WebRTCConnectionManaging
-    }
-
-    private func updateStartupStage(_ stage: ConversationStartupState) {
-        guard state.isConnecting, state != .connecting(stage) else { return }
-        state = .connecting(stage)
-    }
-
-    private func setupAgentStateManager() {
-        guard let configuration = config.agentStateConfiguration else { return }
-        let manager = AgentStateManager(configuration: configuration)
-        manager.onStateChange = { [weak self] state in
-            self?.agentState = state
-            self?.callbacks.onAgentStateChange?(state)
-        }
-        agentStateManager = manager
-    }
-
-    /// Forward a signal to the event-based state manager, or fall back to directly setting `agentState`.
-    private func applyStateSignal(_ signal: AgentStateSignal, fallback: AgentState) {
-        if let manager = agentStateManager {
-            manager.processSignal(signal)
-        } else {
-            agentState = fallback
-        }
-    }
-
-    private func handleRemoteSpeakingUpdate(isSpeaking: Bool) {
-        if let manager = agentStateManager {
-            manager.processSignal(isSpeaking ? .agentStartedSpeaking : .agentStoppedSpeaking)
-        } else if isSpeaking {
-            speakingTimer?.cancel()
-            agentState = .speaking
-        } else {
-            scheduleBackToListening(delay: 1.0)
-        }
-    }
-
     private func start(
         agentId: String,
         isTextOnly: Bool,
@@ -379,6 +344,41 @@ final class Conversation: ObservableObject {
         return result
     }
 
+    private func updateStartupStage(_ stage: ConversationStartupState) {
+        guard state.isConnecting, state != .connecting(stage) else { return }
+        state = .connecting(stage)
+    }
+
+    private func setupAgentStateManager() {
+        guard let configuration = config.agentStateConfiguration else { return }
+        let manager = AgentStateManager(configuration: configuration)
+        manager.onStateChange = { [weak self] state in
+            self?.agentState = state
+            self?.callbacks.onAgentStateChange?(state)
+        }
+        agentStateManager = manager
+    }
+
+    /// Forward a signal to the event-based state manager, or fall back to directly setting `agentState`.
+    private func applyStateSignal(_ signal: AgentStateSignal, fallback: AgentState) {
+        if let manager = agentStateManager {
+            manager.processSignal(signal)
+        } else {
+            agentState = fallback
+        }
+    }
+
+    private func handleRemoteSpeakingUpdate(isSpeaking: Bool) {
+        if let manager = agentStateManager {
+            manager.processSignal(isSpeaking ? .agentStartedSpeaking : .agentStoppedSpeaking)
+        } else if isSpeaking {
+            speakingTimer?.cancel()
+            agentState = .speaking
+        } else {
+            scheduleBackToListening(delay: 1.0)
+        }
+    }
+
     private func handleIncomingEvent(_ event: IncomingEvent, from connectionManagerID: ObjectIdentifier) async {
         guard let activeConnectionManager,
               ObjectIdentifier(activeConnectionManager) == connectionManagerID,