ios - RxSwift-X秒钟未收到项目后发出

我一直在尝试找出一种实现这种行为的方法，但未能找到可行的解决方案。

我想要实现的目标

var dataSource = Variable<[T]>([])

var arrayObserver: Observable<SomeType> {

    return dataSource.asObservable()
        .map({ (elementoftype[T]) in

        // do something with it and return element of SomeType
        })
}

dataSource变量输入1乘以1的值。我希望arrayObserver能够缓冲/“保持”到map ping，直到距dataSource 0.5秒为止。最后发出。

非常感谢您的建议！

最佳答案

原来打电话

.throttle(0.5, MainScheduler.instance)

映射之前完成这项工作。