diff --git a/rxjava-core/src/main/java/rx/operators/OperationThrottle.java b/rxjava-core/src/main/java/rx/operators/OperationThrottle.java index 282347a38e..ebef4e7286 100644 --- a/rxjava-core/src/main/java/rx/operators/OperationThrottle.java +++ b/rxjava-core/src/main/java/rx/operators/OperationThrottle.java @@ -210,11 +210,11 @@ public void before() { public void testThrottlingWithCompleted() { Observable source = Observable.create(new Func1, Subscription>() { @Override - public Subscription call(Observer observser) { - publishNext(observser, 100, "one"); // Should be skipped since "two" will arrive before the timeout expires. - publishNext(observser, 400, "two"); // Should be published since "three" will arrive after the timeout expires. - publishNext(observser, 900, "four"); // Should be skipped since onCompleted will arrive before the timeout expires. - publishCompleted(observser, 1000); // Should be published as soon as the timeout expires. + public Subscription call(Observer observer) { + publishNext(observer, 100, "one"); // Should be skipped since "two" will arrive before the timeout expires. + publishNext(observer, 400, "two"); // Should be published since "three" will arrive after the timeout expires. + publishNext(observer, 900, "four"); // Should be skipped since onCompleted will arrive before the timeout expires. + publishCompleted(observer, 1000); // Should be published as soon as the timeout expires. return Subscriptions.empty(); }