listen to on subscribe success event
@override void onSubscribedSuccess(Function callback) => subscription.onSubscriptionSuccess(callback);