@@ -3916,7 +3916,8 @@ public final <R> Observable<R> flatMap(Func1<? super T, ? extends Observable<? e
3916
3916
* @throws IllegalArgumentException
3917
3917
* if {@code onComplete} is null
3918
3918
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable#wiki-onnext-oncompleted-and-onerror">RxJava Wiki: onNext, onCompleted, and onError</a>
3919
- * */
3919
+ * @since 0.19
3920
+ */
3920
3921
public final void forEach (final Action1 <? super T > onNext ) {
3921
3922
subscribe (onNext );
3922
3923
}
@@ -3937,7 +3938,8 @@ public final void forEach(final Action1<? super T> onNext) {
3937
3938
* @throws IllegalArgumentException
3938
3939
* if {@code onComplete} is null
3939
3940
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable#wiki-onnext-oncompleted-and-onerror">RxJava Wiki: onNext, onCompleted, and onError</a>
3940
- * */
3941
+ * @since 0.19
3942
+ */
3941
3943
public final void forEach (final Action1 <? super T > onNext , final Action1 <Throwable > onError ) {
3942
3944
subscribe (onNext , onError );
3943
3945
}
@@ -3960,7 +3962,8 @@ public final void forEach(final Action1<? super T> onNext, final Action1<Throwab
3960
3962
* @throws IllegalArgumentException
3961
3963
* if {@code onComplete} is null
3962
3964
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable#wiki-onnext-oncompleted-and-onerror">RxJava Wiki: onNext, onCompleted, and onError</a>
3963
- * */
3965
+ * @since 0.19
3966
+ */
3964
3967
public final void forEach (final Action1 <? super T > onNext , final Action1 <Throwable > onError , final Action0 onComplete ) {
3965
3968
subscribe (onNext , onError , onComplete );
3966
3969
}
@@ -4195,6 +4198,7 @@ public final Observable<T> lastOrDefault(T defaultValue, Func1<? super T, Boolea
4195
4198
* @return an Observable that emits only the first {@code num} items emitted by the source Observable, or
4196
4199
* all of the items from the source Observable if that Observable emits fewer than {@code num} items
4197
4200
* @see <a href="https://github.com/Netflix/RxJava/wiki/Filtering-Observables#wiki-take">RxJava Wiki: take()</a>
4201
+ * @since 0.19
4198
4202
*/
4199
4203
public final Observable <T > limit (int num ) {
4200
4204
return take (num );
0 commit comments