Minor cleanup
This commit is contained in:
@@ -922,7 +922,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
|
|||||||
.transform(mono -> {
|
.transform(mono -> {
|
||||||
mono = Mono.from((Publisher) mono).map(v -> this.extractValueFromOriginalValueHolderIfNecessary(v));
|
mono = Mono.from((Publisher) mono).map(v -> this.extractValueFromOriginalValueHolderIfNecessary(v));
|
||||||
((Consumer) this.target).accept(mono);
|
((Consumer) this.target).accept(mono);
|
||||||
return Mono.ignoreElements((Flux) mono);
|
return Mono.ignoreElements((Mono) mono);
|
||||||
}).then();
|
}).then();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user