1. @override
dynamic onSubscribe()

Source

@override
onSubscribe() {
  if (onSubscribeCallback != null) {
    return onSubscribeCallback();
  }
}