当我在FlowableOnSubscribe类中调用onNext时，订户的onNext和onComplete函数无法运行

当我在FlowableOnSubscribe类中调用onNext时，订户的onNext和onComplete函数无法运行

您需要手动发出请求，否则

Subscriber

直接扩展时将不会发出任何数据：

@Overridepublic void onSubscribe(Subscription s) {    Log.i(TAG, "onSubscribe");    s.request(Long.MAX_VALUE);}

或者，您可以扩展

DisposableSubscriber

或

ResourceSubscriber

。