gistfile1.txt

webSocketService.publisher
    .buffer(size: 1, prefetch: .keepFull, whenFull: .dropOldest)
    .compactMap { data -> AuctionBid? in
        try? decoder.decode(AuctionBid.self, from: data)
    }
    .scan([]) { (history: [AuctionBid], newBid) in
        history + [newBid]
    }
    .receive(on: RunLoop.main)
    .sink(receiveCompletion: { print($0) },
          receiveValue: { bids in
        withAnimation {
            bidHistory = bids
            highestBid = bids.last
            timeRemaining = bids.last?.timeRemaining ?? 0
        }
    })
    .store(in: &cancellables)