purchaseStateStream method

  1. @override
Stream<PurchaseState> purchaseStateStream()
override

Implementation

@override
Stream<PurchaseState> purchaseStateStream() {
  // clean streams
  _cleanStreams(_streamControllerPurchaseState);
  // create new stream controller
  var controller = StreamController<PurchaseState>();
  _streamControllerPurchaseState.add(controller);
  controller.add(_purchaseState);
  return controller.stream;
}