File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
rxjava-core/src/main/java/rx/operators Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -210,11 +210,11 @@ public void before() {
210
210
public void testThrottlingWithCompleted () {
211
211
Observable <String > source = Observable .create (new Func1 <Observer <String >, Subscription >() {
212
212
@ Override
213
- public Subscription call (Observer <String > observser ) {
214
- publishNext (observser , 100 , "one" ); // Should be skipped since "two" will arrive before the timeout expires.
215
- publishNext (observser , 400 , "two" ); // Should be published since "three" will arrive after the timeout expires.
216
- publishNext (observser , 900 , "four" ); // Should be skipped since onCompleted will arrive before the timeout expires.
217
- publishCompleted (observser , 1000 ); // Should be published as soon as the timeout expires.
213
+ public Subscription call (Observer <String > observer ) {
214
+ publishNext (observer , 100 , "one" ); // Should be skipped since "two" will arrive before the timeout expires.
215
+ publishNext (observer , 400 , "two" ); // Should be published since "three" will arrive after the timeout expires.
216
+ publishNext (observer , 900 , "four" ); // Should be skipped since onCompleted will arrive before the timeout expires.
217
+ publishCompleted (observer , 1000 ); // Should be published as soon as the timeout expires.
218
218
219
219
return Subscriptions .empty ();
220
220
}
You can’t perform that action at this time.
0 commit comments