diff --git a/src/main/java/reactor/core/publisher/FluxMapSignal.java b/src/main/java/reactor/core/publisher/FluxMapSignal.java
index 484db5bc48..51a3308633 100644
--- a/src/main/java/reactor/core/publisher/FluxMapSignal.java
+++ b/src/main/java/reactor/core/publisher/FluxMapSignal.java
@@ -37,7 +37,7 @@
 final class FluxMapSignal<T, R> extends FluxSource<T, R> {
 
     final Function<? super T, ? extends R> mapperNext;
-    final Function<Throwable, ? extends R> mapperError;
+    final Function<? super Throwable, ? extends R> mapperError;
     final Supplier<? extends R>            mapperComplete;
 
     /**
@@ -52,7 +52,7 @@ final class FluxMapSignal<T, R> extends FluxSource<T, R> {
      */
     FluxMapSignal(Publisher<? extends T> source,
             Function<? super T, ? extends R> mapperNext,
-            Function<Throwable, ? extends R> mapperError,
+            Function<? super Throwable, ? extends R> mapperError,
             Supplier<? extends R>            mapperComplete) {
         super(source);
 	    if(mapperNext == null && mapperError == null && mapperComplete == null){
diff --git a/src/main/java/reactor/core/publisher/FluxRetryPredicate.java b/src/main/java/reactor/core/publisher/FluxRetryPredicate.java
index 6c612dce23..f7eacff4e7 100644
--- a/src/main/java/reactor/core/publisher/FluxRetryPredicate.java
+++ b/src/main/java/reactor/core/publisher/FluxRetryPredicate.java
@@ -31,9 +31,9 @@
  */
 final class FluxRetryPredicate<T> extends FluxSource<T, T> {
 
-	final Predicate<Throwable> predicate;
+	final Predicate<? super Throwable> predicate;
 
-	FluxRetryPredicate(Flux<? extends T> source, Predicate<Throwable> predicate) {
+	FluxRetryPredicate(Flux<? extends T> source, Predicate<? super Throwable> predicate) {
 		super(source);
 		this.predicate = Objects.requireNonNull(predicate, "predicate");
 	}
@@ -56,7 +56,7 @@ static final class RetryPredicateSubscriber<T>
 
 		final Publisher<? extends T> source;
 
-		final Predicate<Throwable> predicate;
+		final Predicate<? super Throwable> predicate;
 
 		volatile int wip;
 		@SuppressWarnings("rawtypes")
@@ -66,7 +66,7 @@ static final class RetryPredicateSubscriber<T>
 		long produced;
 
 		RetryPredicateSubscriber(Publisher<? extends T> source,
-				Subscriber<? super T> actual, Predicate<Throwable> predicate) {
+				Subscriber<? super T> actual, Predicate<? super Throwable> predicate) {
 			super(actual);
 			this.source = source;
 			this.predicate = predicate;
diff --git a/src/main/java/reactor/core/publisher/Mono.java b/src/main/java/reactor/core/publisher/Mono.java
index 4e585ef080..54a5974f4e 100644
--- a/src/main/java/reactor/core/publisher/Mono.java
+++ b/src/main/java/reactor/core/publisher/Mono.java
@@ -2049,7 +2049,7 @@ public final <R> Flux<R> flatMapMany(Function<? super T, ? extends Publisher<? e
 	 * @see Flux#flatMap(Function, Function, Supplier)
 	 */
 	public final <R> Flux<R> flatMapMany(Function<? super T, ? extends Publisher<? extends R>> mapperOnNext,
-			Function<Throwable, ? extends Publisher<? extends R>> mapperOnError,
+			Function<? super Throwable, ? extends Publisher<? extends R>> mapperOnError,
 			Supplier<? extends Publisher<? extends R>> mapperOnComplete) {
 
 		return Flux.onAssembly(new FluxFlatMap<>(
@@ -2366,7 +2366,7 @@ public final Flux<T> mergeWith(Publisher<? extends T> other) {
 	 *
 	 * @return a transformed {@link Mono}
 	 */
-	public final Mono<T> onErrorMap(Function<Throwable, ? extends Throwable> mapper) {
+	public final Mono<T> onErrorMap(Function<? super Throwable, ? extends Throwable> mapper) {
 		return onErrorResume(e -> Mono.error(mapper.apply(e)));
 	}
 
diff --git a/src/main/java/reactor/core/publisher/MonoRetryPredicate.java b/src/main/java/reactor/core/publisher/MonoRetryPredicate.java
index b578c07400..51efb64e18 100644
--- a/src/main/java/reactor/core/publisher/MonoRetryPredicate.java
+++ b/src/main/java/reactor/core/publisher/MonoRetryPredicate.java
@@ -30,10 +30,10 @@
  */
 final class MonoRetryPredicate<T> extends MonoSource<T, T> {
 
-	final Predicate<Throwable> predicate;
+	final Predicate<? super Throwable> predicate;
 
 	MonoRetryPredicate(Mono<? extends T> source,
-			Predicate<Throwable> predicate) {
+			Predicate<? super Throwable> predicate) {
 		super(source);
 		this.predicate = Objects.requireNonNull(predicate, "predicate");
 	}