Как с помощью оператора RxSwift выбрать сразу все элементы?

Допустим, у меня есть табличное представление продуктов.

Вот моя модель просмотра:

ProductViewModel.swift

var selectedObserver: AnyObserver<Product>
var state: Driver<Set<Product>>
var selectedSubject = PublishSubject<Product>()

self.selectedObserver = selectedSubject.asObserver()

self.state =
        selectedSubject.asObservable()
        .scan(Set()) { (acc: Set<Product>, item: Product) in
            var acc = acc
            if acc.contains(item) {
                acc.remove(item)
            } else {
                acc.insert(item)
            }
            return acc
        }
        .startWith(Set())
        .asDriver(onErrorJustReturn: Set())

 self.isSelectedAll = Driver
        .combineLatest(
            self.state.map { $0.count },
            envelope.map { $0.products.count })
        .debug()
        .map { $0.0 == $0.1 }

Как видите, каждый раз, когда я выбираю объект, я переводю его в состояние observable, чтобы затем ячейка могла наблюдать за изменением состояния.

Вот привязка RxSwift между ячейкой и viewModel:

ProductViewController.swift

self.viewModel.deliveries
        .drive(self.tableView.rx.items(cellIdentifier: DeliveryTableViewCellReusableIdentifier, cellType: DeliveryTableViewCell.self)) { (_, item, cell) in
            cell.bind(to: self.viewModel.state, as: item)
            cell.configureWith(product: item)
        }
        .disposed(by: disposeBag)

self.tableView.rx.modelSelected(Product.self)
        .asDriver()
        .drive(self.viewModel.selectedObserver)
        .disposed(by: disposeBag)

ProductCell.swift

func bind(to state: Driver<Set<Product>>, as item: Product) {
    state.map { $0.contains(item) }
    .drive(self.rx.isSelected)
    .disposed(by: rx.reuseBag)
}

Что ж, пока все хорошо.

Теперь мой вопрос: как я могу выбрать все действие, например. нажатие кнопки «Выбрать все», чтобы все продукты каким-то образом были scan в состояниях?