您需要手动发出请求,否则
Subscriber直接扩展时将不会发出任何数据:
@Overridepublic void onSubscribe(Subscription s) { Log.i(TAG, "onSubscribe"); s.request(Long.MAX_VALUE);}或者,您可以扩展
DisposableSubscriber或
ResourceSubscriber。

您需要手动发出请求,否则
Subscriber直接扩展时将不会发出任何数据:
@Overridepublic void onSubscribe(Subscription s) { Log.i(TAG, "onSubscribe"); s.request(Long.MAX_VALUE);}或者,您可以扩展
DisposableSubscriber或
ResourceSubscriber。