如何从rxswift延迟收藏中发出项目

Question

我想创建一个可观察到的collection可观察到的，在延迟后，将逐一发射每个元素。另外，我想对项目（型号）执行一些更新。

例如：

//一一喂食所有狗，间隔为5秒。

class Dog {
    var name: String?
    var age: Int?
    var feeded = false
    init(_ name: String, _ age: Int){
        self.name = name
        self.age = age
    }
}
func feedDogs(){
    let dog1 = Dog("Ren", 3)
    let dog2 = Dog("Bega", 7)
    let dog3 = Dog("Xuxu", 11)
    let delay = 6 // seconds
    let allDogs = [dog1, dog2, dog3]
    // Observable....
    // Expected results after subscribe
    //   Start - > 0 seconds
    // dog1.feeded // true
    //   time lapse -> 6 seconds
    // dog2. feeded  // true
    //    timelapse -> 12 seconds
    // dog3.feeded // true
}

我尝试使用" zip"喜欢" zipwith"（在rxjava中），但似乎不支持rxswift。

Answer 1

好吧...在一些R＆amp; d之后，这是我问题的测试工作版本。

Observable.zip(Observable.from(allDogs), Observable<Int>.interval(RxTimeInterval(delay), scheduler: MainScheduler.instance)).subscribe(onNext: { (dog, index) in
            print(dog.name)
        }
    )

Answer 2

我为此目的写了扩展。

extension Observable {
    func with(interval: RxTimeInterval) -> Observable {
        return enumerated()
            .concatMap { index, element in
                Observable
                    .just(element)
                    .delay(index == 0 ? RxTimeInterval.seconds(0) : interval,
                           scheduler: MainScheduler.instance)
            }
    }
}

样本：

Observable.from([1, 2, 3, 4, 5])
    .with(interval: RxTimeInterval.seconds(1))
    .subscribe(onNext: {
        print($0)
    })
    .disposed(by: disposeBag)

Answer 3

嗯，我能想到的最简单的方式（虽然不是那么优雅）。

您创建一个计时器。

let timer = Timer.scheduledTimer(timeInterval: 5, target: self, selector: #selector(count), userInfo: nil, repeats: true)

和一个计数器

 var counter : Int = 0

在选择器中执行此操作

@objc func count(){
    print("i am being here")
    rxTimer.value = ()
}

其中rxtimer是定义的变量

var rxTimer = Variable<(())>(())

然后，您只需称观察rxtimer为

rxTimer.asDriver()
        .map { (_) -> Int? in
            if self.counter == collection.count{
                timer.invalidate()
                return nil
            }
            let value = collection[self.counter]
            self.counter += 1
            return value
    }
        .filter{$0 != nil}
        .map{$0!}

collectio是您定义的集合。在这里，我将其定义为INT，但您可以将其定义为您想要的任何东西。