diff --git a/src/main/java/net/openhft/chronicle/map/MapStatelessClient.java b/src/main/java/net/openhft/chronicle/map/MapStatelessClient.java index b6908e323..f47a46fde 100644 --- a/src/main/java/net/openhft/chronicle/map/MapStatelessClient.java +++ b/src/main/java/net/openhft/chronicle/map/MapStatelessClient.java @@ -31,19 +31,24 @@ public abstract class MapStatelessClient extends @Nullable protected R proxyReturnTypedObject( @NotNull final E eventId, - R usingValue, + @Nullable R usingValue, @NotNull final Class resultType, @Nullable Object... args) { - Function consumerIn = resultType == CharSequence.class && usingValue != null - ? f -> { + final Function valueInRFunction = f -> { f.text((StringBuilder) usingValue); return usingValue; - } - : f -> f.object(resultType); + }; + + final Function consumerIn = + resultType == CharSequence.class && usingValue != null + ? valueInRFunction + : f -> f.object(resultType); + return proxyReturnWireConsumerInOut(eventId, CoreFields.reply, toParameters(eventId, args), consumerIn); } + }