@@ -58,7 +58,7 @@ open class Conversation: ObservableObject {
5858
5959 public let room : Room
6060
61- private let credentials : any CredentialsProvider
61+ private let tokenSource : any TokenSource
6262 private let senders : [ any MessageSender ]
6363 private let receivers : [ any MessageReceiver ]
6464
@@ -68,8 +68,8 @@ open class Conversation: ObservableObject {
6868
6969 // MARK: - Init
7070
71- public init ( credentials : CredentialsProvider , room: Room = . init( ) , agentName: String ? = nil , senders: [ any MessageSender ] ? = nil , receivers: [ any MessageReceiver ] ? = nil ) {
72- self . credentials = credentials
71+ public init ( tokenSource : TokenSource , room: Room = . init( ) , agentName: String ? = nil , senders: [ any MessageSender ] ? = nil , receivers: [ any MessageReceiver ] ? = nil ) {
72+ self . tokenSource = tokenSource
7373 self . room = room
7474
7575 let textMessageSender = TextMessageSender ( room: room)
@@ -155,11 +155,11 @@ open class Conversation: ObservableObject {
155155 if preConnectAudio {
156156 try await room. withPreConnectAudio ( timeout: waitForAgent) {
157157 await MainActor . run { self . isListening = true }
158- try await self . room. connect ( credentialsProvider : self . credentials , connectOptions: options, roomOptions: roomOptions)
158+ try await self . room. connect ( tokenSource : self . tokenSource , connectOptions: options, roomOptions: roomOptions)
159159 await MainActor . run { self . isListening = false }
160160 }
161161 } else {
162- try await room. connect ( credentialsProvider : credentials , connectOptions: options, roomOptions: roomOptions)
162+ try await room. connect ( tokenSource : tokenSource , connectOptions: options, roomOptions: roomOptions)
163163 }
164164 } catch {
165165 self . error = . failedToConnect( error)
0 commit comments