RxObservableQueue

使用 RxObservableQueue，您可以像管理队列一样管理 Observables。RxObservableQueue 是用于在需要时包含已发出对象和发出对象的包装器。

功能

需求

• iOS 8.0+
• Xcode 9.3+
• RxSwift

安装

RxObservableQueue 通过 CocoaPods 和 Carthage 提供。

CocoaPods

要安装，只需在 Podfile 中添加以下行即可

platform :ios, '11.0'
use_frameworks!

pod 'RxObservableQueue'

Carthage

要将RxObservableQueue集成到您的Xcode项目中并使用Carthage，请在您的Cartfile中指定它。

github "notohiro/RxObservableQueue"

运行carthage update来构建框架并将构建的RxObservableQueue.framework拖动到您的Xcode项目中。

使用方法

使用可观察对象和并发数进行初始化。

queue = RxObservableQueue
  .create(observable: someObservable, maxConcurrentCount: 3)

订阅并发送当需要下一个对象时，请发出signal()信号。

queue.subscribe(onNext: { item, counter in
  // do some time-consuming task
  doSomeOperation(item) {
    // send signal() to pop next task from queue
    counter.signal()
  }
  })
  .addDisposableTo(bag)

作者

许可证

RxObservableQueue遵循MIT许可证。有关更多信息，请参阅LICENSE文件。