1. @override
dynamic onSubscribe()

Source

@override
onSubscribe() {
  subscriptionCount++;
  checkSubscriptionNeeded();
}