.swift

final class Conversation: ObservableObject {
    private let session = Session()
    private var messageSubscriber: AnyCancellable?
    
    init() {
        messageSubscriber = session.messageFeed.sink { [weak self] (receivedMessage) in
            self?.messages.append(receivedMessage)
        }
    }
    
    @Published private(set) var messages = [Message]()
    
    func send(_ message: Message) {
        session.send(message)
    }
}