Skip to content

Commit

Permalink
Alignment with other abstract utils classes
Browse files Browse the repository at this point in the history
  • Loading branch information
jhoeller committed Sep 14, 2021
1 parent 4322ee1 commit 3baaced
Showing 1 changed file with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,10 +45,7 @@
* @author Phillip Webb
* @since 5.2
*/
public final class CoroutinesUtils {

private CoroutinesUtils() {
}
public abstract class CoroutinesUtils {

/**
* Convert a {@link Deferred} instance to a {@link Mono}.
Expand Down Expand Up @@ -78,7 +75,7 @@ public static Publisher<?> invokeSuspendingFunction(Method method, Object target
KCallables.callSuspend(function, getSuspendedFunctionArgs(target, args), continuation))
.filter(result -> !Objects.equals(result, Unit.INSTANCE))
.onErrorMap(InvocationTargetException.class, InvocationTargetException::getTargetException);
if (classifier.equals(JvmClassMappingKt.getKotlinClass(Flow.class))) {
if (classifier != null && classifier.equals(JvmClassMappingKt.getKotlinClass(Flow.class))) {
return mono.flatMapMany(CoroutinesUtils::asFlux);
}
return mono;
Expand Down

0 comments on commit 3baaced

Please sign in to comment.