rxswift实现定时器

rxswift_timer_interval.swift

        let interval = Observable<Int>.interval(0.6, scheduler: MainScheduler.instance)
        let disinterval = interval.subscribe(onNext: { (time) in
            guard time < lines.count else {
                return
            }
            
            self.searchBusLine(lineId: lines[time].gid)
        })
        let timeE:DispatchTime = DispatchTime.now() + Double(lines.count*Int(NSEC_PER_SEC)) / Double(NSEC_PER_SEC);
        DispatchQueue.main.asyncAfter(deadline: timeE) {
            disinterval.dispose()
        }