gistfile1.txt

.onAppear {
    webSocketService.publisher
        .decode(type: ThermostatState.self, decoder: decoder)
        .receive(on: RunLoop.main)
        .throttle(for: .seconds(0.25), scheduler: RunLoop.main, latest: true)
        .sink(receiveCompletion: { print($0) },
              receiveValue: { state in
            if state.temperature > maxTemperature {
                showOverheatWarning = true
            } else {
                withAnimation(.spring()) {
                    currentState = state
                }
            }
        })
        .store(in: &cancellables)
}