simplified error handling as this is already done on the outside

Author: Joachim Hofer

rxjava-core/src/main/java/rx/operators/OperationDistinct.java

@@ -120,15 +120,10 @@ public void onError(Throwable e) {
 
                 @Override
                 public void onNext(T next) {
-                    try {
-                        U nextKey = keySelector.call(next);
-                        if (!emittedKeys.contains(nextKey)) {
-                            emittedKeys.add(nextKey);
-                            observer.onNext(next);
-                        }
-                    } catch (Throwable t) {
-                        // keySelector is a user function, may throw something
-                        observer.onError(t);
+                    U nextKey = keySelector.call(next);
+                    if (!emittedKeys.contains(nextKey)) {
+                        emittedKeys.add(nextKey);
+                        observer.onNext(next);
                     }
                 }
             });
@@ -172,15 +167,10 @@ public void onError(Throwable e) {
 
                 @Override
                 public void onNext(T next) {
-                    try {
-                        U nextKey = keySelector.call(next);
-                        if (!alreadyEmitted(nextKey)) {
-                            emittedKeys.add(nextKey);
-                            observer.onNext(next);
-                        }
-                    } catch (Throwable t) {
-                        // keySelector and comparator are user functions, may throw something
-                        observer.onError(t);
+                    U nextKey = keySelector.call(next);
+                    if (!alreadyEmitted(nextKey)) {
+                        emittedKeys.add(nextKey);
+                        observer.onNext(next);
                     }
                 }
 

rxjava-core/src/main/java/rx/operators/OperationDistinctUntilChanged.java

@@ -133,18 +133,13 @@ public void onError(Throwable e) {
                 @Override
                 public void onNext(T next) {
                     U lastKey = lastEmittedKey;
-                    try {
-                        U nextKey = keySelector.call(next);
-                        lastEmittedKey = nextKey;
-                        if (!hasEmitted) {
-                            hasEmitted = true;
-                            observer.onNext(next);
-                        } else if (equalityComparator.compare(lastKey, nextKey) != 0) {
-                            observer.onNext(next);
-                        }
-                    } catch (Throwable t) {
-                        // keySelector is a user function, may throw something
-                        observer.onError(t);
+                    U nextKey = keySelector.call(next);
+                    lastEmittedKey = nextKey;
+                    if (!hasEmitted) {
+                        hasEmitted = true;
+                        observer.onNext(next);
+                    } else if (equalityComparator.compare(lastKey, nextKey) != 0) {
+                        observer.onNext(next);
                     }
                 }
             });