diff --git a/src/main/java/rx/Observable.java b/src/main/java/rx/Observable.java
index 0a2ebab8ce..f7aa65dbc3 100644
--- a/src/main/java/rx/Observable.java
+++ b/src/main/java/rx/Observable.java
@@ -5592,8 +5592,8 @@ public final <T2, D1, D2, R> Observable<R> groupJoin(Observable<T2> right, Func1
      *         called by the source Observable
      * @see <a href="http://reactivex.io/documentation/operators/ignoreelements.html">ReactiveX operators documentation: IgnoreElements</a>
      */
-    public final Observable<T> ignoreElements() {
-        return lift(OperatorIgnoreElements.<T> instance());
+    public final <R> Observable<R> ignoreElements() {
+        return lift(OperatorIgnoreElements.<R, T>instance());
     }
 
     /**
diff --git a/src/main/java/rx/internal/operators/OperatorIgnoreElements.java b/src/main/java/rx/internal/operators/OperatorIgnoreElements.java
index 3f38d8e585..6d4622cca4 100644
--- a/src/main/java/rx/internal/operators/OperatorIgnoreElements.java
+++ b/src/main/java/rx/internal/operators/OperatorIgnoreElements.java
@@ -18,15 +18,15 @@
 import rx.Observable.Operator;
 import rx.Subscriber;
 
-public class OperatorIgnoreElements<T> implements Operator<T, T> {
+public class OperatorIgnoreElements<R, T> implements Operator<R, T> {
 
     private static class Holder {
-        static final OperatorIgnoreElements<?> INSTANCE = new OperatorIgnoreElements<Object>();
+        static final OperatorIgnoreElements<?, ?> INSTANCE = new OperatorIgnoreElements<Object, Object>();
     }
     
     @SuppressWarnings("unchecked")
-    public static <T> OperatorIgnoreElements<T> instance() {
-        return (OperatorIgnoreElements<T>) Holder.INSTANCE;
+    public static <T, R> OperatorIgnoreElements<T, R> instance() {
+        return (OperatorIgnoreElements<T, R>) Holder.INSTANCE;
     }
 
     private OperatorIgnoreElements() {
@@ -34,7 +34,7 @@ private OperatorIgnoreElements() {
     }
 
     @Override
-    public Subscriber<? super T> call(final Subscriber<? super T> child) {
+    public Subscriber<? super T> call(final Subscriber<? super R> child) {
         Subscriber<T> parent = new Subscriber<T>() {
 
             @Override
diff --git a/src/test/java/rx/internal/operators/OperatorIgnoreElementsTest.java b/src/test/java/rx/internal/operators/OperatorIgnoreElementsTest.java
index 818f228ba8..b1bf94324d 100644
--- a/src/test/java/rx/internal/operators/OperatorIgnoreElementsTest.java
+++ b/src/test/java/rx/internal/operators/OperatorIgnoreElementsTest.java
@@ -92,7 +92,7 @@ public void call(Integer t) {
                     }
                 })
                 //
-                .ignoreElements()
+                .<Integer>ignoreElements()
                 //
                 .doOnNext(new Action1<Integer>() {