Reactive extensions of StoreKit
Create observable sequence of responses for SKProductRequest and subscribe it
SKProduct.rx.request(with: ["xxxxx"])
.subscribe(onNext: { response in
let products = response.products
})
.dispose()
or
let request = SKProductsRequest.init(productIdentifiers: ["product_id"])
request.rx.response.subscribe { event in
switch event {
case .next(let response):
let products = response.products
default:
return
}
}
.dispose()
SKPaymentQueue.default().rx.updatedTransaction
.subscribe(onNext: { transaction in
// Do what you want
})
.dispose()
paymentQueue.rx.productIdentifiersWithRevokedEntitlements
.subscribe { productIdentifier in
// Do what you want
}