1. @override
dynamic onSubscribe()

Source 

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