gistfile1.txt

private func receiveNextMessage() async throws {
    guard let webSocketTask else { return }
    
    do {
        let message = try await webSocketTask.receive()
        switch message {
        case .string(let string):
            dataSubject.send(string.data(using: .utf8) ?? Data())
        case .data(let data):
            dataSubject.send(data)
        @unknown default:
            break
        }
    } catch {
        dataSubject.send(completion: .failure(error))
        throw error 
    }
}