@@ -143,7 +143,7 @@ public void onCompleted() {
143
143
}
144
144
145
145
/**
146
- * Get the {@link Notification}s representing each time this {@link Subscriber} was notified of sequence
146
+ * Returns the {@link Notification}s representing each time this {@link Subscriber} was notified of sequence
147
147
* completion via {@link #onCompleted}, as a {@link List}.
148
148
*
149
149
* @return a list of Notifications representing calls to this Subscriber's {@link #onCompleted} method
@@ -172,7 +172,7 @@ public void onError(Throwable e) {
172
172
}
173
173
174
174
/**
175
- * Get the {@link Throwable}s this {@link Subscriber} was notified of via {@link #onError} as a
175
+ * Returns the {@link Throwable}s this {@link Subscriber} was notified of via {@link #onError} as a
176
176
* {@link List}.
177
177
*
178
178
* @return a list of the Throwables that were passed to this Subscriber's {@link #onError} method
@@ -199,7 +199,7 @@ public void onNext(T t) {
199
199
}
200
200
201
201
/**
202
- * Allow calling the protected {@link #request(long)} from unit tests.
202
+ * Allows calling the protected {@link #request(long)} from unit tests.
203
203
*
204
204
* @param n the maximum number of items you want the Observable to emit to the Subscriber at this time, or
205
205
* {@code Long.MAX_VALUE} if you want the Observable to emit items at its own pace
@@ -209,7 +209,7 @@ public void requestMore(long n) {
209
209
}
210
210
211
211
/**
212
- * Get the sequence of items observed by this {@link Subscriber}, as an ordered {@link List}.
212
+ * Returns the sequence of items observed by this {@link Subscriber}, as an ordered {@link List}.
213
213
*
214
214
* @return a list of items observed by this Subscriber, in the order in which they were observed
215
215
*/
@@ -218,7 +218,7 @@ public List<T> getOnNextEvents() {
218
218
}
219
219
220
220
/**
221
- * Assert that a particular sequence of items was received by this {@link Subscriber} in order.
221
+ * Asserts that a particular sequence of items was received by this {@link Subscriber} in order.
222
222
*
223
223
* @param items
224
224
* the sequence of items expected to have been observed
@@ -230,7 +230,7 @@ public void assertReceivedOnNext(List<T> items) {
230
230
}
231
231
232
232
/**
233
- * Assert that a single terminal event occurred, either {@link #onCompleted} or {@link #onError}.
233
+ * Asserts that a single terminal event occurred, either {@link #onCompleted} or {@link #onError}.
234
234
*
235
235
* @throws AssertionError
236
236
* if not exactly one terminal event notification was received
@@ -240,7 +240,7 @@ public void assertTerminalEvent() {
240
240
}
241
241
242
242
/**
243
- * Assert that this {@code Subscriber} is unsubscribed.
243
+ * Asserts that this {@code Subscriber} is unsubscribed.
244
244
*
245
245
* @throws AssertionError
246
246
* if this {@code Subscriber} is not unsubscribed
@@ -252,7 +252,7 @@ public void assertUnsubscribed() {
252
252
}
253
253
254
254
/**
255
- * Assert that this {@code Subscriber} has received no {@code onError} notifications.
255
+ * Asserts that this {@code Subscriber} has received no {@code onError} notifications.
256
256
*
257
257
* @throws AssertionError
258
258
* if this {@code Subscriber} has received one or more {@code onError} notifications
@@ -335,7 +335,7 @@ public Thread getLastSeenThread() {
335
335
}
336
336
337
337
/**
338
- * Assert if there is exactly a single completion event.
338
+ * Asserts that there is exactly one completion event.
339
339
*
340
340
* @throws AssertionError if there were zero, or more than one, onCompleted events
341
341
* @since (if this graduates from "Experimental" replace this parenthetical with the release number)
@@ -352,7 +352,7 @@ public void assertCompleted() {
352
352
}
353
353
354
354
/**
355
- * Assert if there is no completion event.
355
+ * Asserts that there is no completion event.
356
356
*
357
357
* @throws AssertionError if there were one or more than one onCompleted events
358
358
* @since (if this graduates from "Experimental" replace this parenthetical with the release number)
@@ -369,7 +369,7 @@ public void assertNotCompleted() {
369
369
}
370
370
371
371
/**
372
- * Assert if there is exactly one error event which is a subclass of the given class.
372
+ * Asserts that there is exactly one error event which is a subclass of the given class.
373
373
*
374
374
* @param clazz the class to check the error against.
375
375
* @throws AssertionError if there were zero, or more than one, onError events, or if the single onError
@@ -395,7 +395,7 @@ public void assertError(Class<? extends Throwable> clazz) {
395
395
}
396
396
397
397
/**
398
- * Assert there is a single onError event with the exact exception.
398
+ * Asserts that there is a single onError event with the exact exception.
399
399
*
400
400
* @param throwable the throwable to check
401
401
* @throws AssertionError if there were zero, or more than one, onError events, or if the single onError
@@ -421,7 +421,7 @@ public void assertError(Throwable throwable) {
421
421
}
422
422
423
423
/**
424
- * Assert for no onError and onCompleted events.
424
+ * Asserts that there are no onError and onCompleted events.
425
425
*
426
426
* @throws AssertionError if there was either an onError or onCompleted event
427
427
* @since (if this graduates from "Experimental" replace this parenthetical with the release number)
@@ -447,7 +447,7 @@ public void assertNoTerminalEvent() {
447
447
}
448
448
449
449
/**
450
- * Assert if there are no onNext events received.
450
+ * Asserts that there are no onNext events received.
451
451
*
452
452
* @throws AssertionError if there were any onNext events
453
453
* @since (if this graduates from "Experimental" replace this parenthetical with the release number)
@@ -461,7 +461,7 @@ public void assertNoValues() {
461
461
}
462
462
463
463
/**
464
- * Assert if the given number of onNext events are received.
464
+ * Asserts that the given number of onNext events are received.
465
465
*
466
466
* @param count the expected number of onNext events
467
467
* @throws AssertionError if there were more or fewer onNext events than specified by {@code count}
@@ -476,7 +476,7 @@ public void assertValueCount(int count) {
476
476
}
477
477
478
478
/**
479
- * Assert if the received onNext events, in order, are the specified items.
479
+ * Asserts that the received onNext events, in order, are the specified items.
480
480
*
481
481
* @param values the items to check
482
482
* @throws AssertionError if the items emitted do not exactly match those specified by {@code values}
@@ -488,7 +488,7 @@ public void assertValues(T... values) {
488
488
}
489
489
490
490
/**
491
- * Assert if there is only a single received onNext event and that it marks the emission of a specific item.
491
+ * Asserts that there is only a single received onNext event and that it marks the emission of a specific item.
492
492
*
493
493
* @param value the item to check
494
494
* @throws AssertionError if the Observable does not emit only the single item specified by {@code value}
0 commit comments