RxSwift - X秒間アイテムを受信しなかった後に放出します

Question

私はこのような動作を実装する方法を見つけようとしていましたが、実際の解決策には出られませんでした。

私が達成したい何

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変数は、私はそれまでmapのpingに「ホールド」/バッファリングすることができるようにarrayObserverをしたい値が1で1に来て供給され、例えば、dataSourceが最後に放出されてから0.5秒であった。

お寄せいただきありがとうございます！

Answer 1

は、マッピングが仕事をしていません前に

.throttle(0.5, MainScheduler.instance) 

を呼び出す判明します。