@@ -5518,7 +5518,7 @@ public Observable<T> doOnEach(Observer<? super T> observer) {
5518
5518
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#dooneach">RxJava Wiki: doOnEach()</a>
5519
5519
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229804.aspx">MSDN: Observable.Do</a>
5520
5520
*/
5521
- public Observable <T > doOnEach (final Action1 <T > onNext ) {
5521
+ public Observable <T > doOnEach (final Action1 <? super T > onNext ) {
5522
5522
Observer <T > observer = new Observer <T >() {
5523
5523
@ Override
5524
5524
public void onCompleted () {}
@@ -5609,7 +5609,7 @@ public void onNext(T args) { }
5609
5609
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#dooneach">RxJava Wiki: doOnEach()</a>
5610
5610
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229539.aspx">MSDN: Observable.Do</a>
5611
5611
*/
5612
- public Observable <T > doOnEach (final Action1 <T > onNext , final Action1 <Throwable > onError ) {
5612
+ public Observable <T > doOnEach (final Action1 <? super T > onNext , final Action1 <Throwable > onError ) {
5613
5613
Observer <T > observer = new Observer <T >() {
5614
5614
@ Override
5615
5615
public void onCompleted () {}
@@ -5644,7 +5644,7 @@ public void onNext(T args) {
5644
5644
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#dooneach">RxJava Wiki: doOnEach()</a>
5645
5645
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229830.aspx">MSDN: Observable.Do</a>
5646
5646
*/
5647
- public Observable <T > doOnEach (final Action1 <T > onNext , final Action1 <Throwable > onError , final Action0 onCompleted ) {
5647
+ public Observable <T > doOnEach (final Action1 <? super T > onNext , final Action1 <Throwable > onError , final Action0 onCompleted ) {
5648
5648
Observer <T > observer = new Observer <T >() {
5649
5649
@ Override
5650
5650
public void onCompleted () {
0 commit comments