backpressure_test:测试OperatorDoOnSubscribe和OperatorDoOnUnsubscrib...

在使用Observable doOnSubscribe和doOnUnsubscribe方法时遇到了一些奇怪的行为。 原因是那些方法使用运算符OperatorDoOnSubscribe和OperatorDoOnUnsubscribe 。 public class OperatorDoOnSubscribe <T> implements Operator< T> { private final Action0 subscribe; /** * Constructs an instance of the operator with the callback that gets invoked when the modified Observable is subscribed * @param subscribe the action that