subscribe.swift

Observable
    .merge(
        stringStream.map { Value.string($0) },
        intStream.map { Value.int($0) }
    )
    .debounce(.seconds(1), scheduler: MainScheduler.instance)
    .subscribe(onNext: {
        switch $0 {
        case let .string(string):
            print(string)
        case let .int(int):
            print(int)
        }
    })
    .disposed(by: disposeBag)