SendUtils onDiscard handler class cast exception about rsocket-java

[OlegDokuka]

@Svenskunganka! Sounds relevant!

Feel free to contribute if you see the direct solution, otherwise, I will investigate it!

Best,
Oleh

[Svenskunganka]

Hi Oleh!

If my possible solution is acceptable I can definitely contribute it! But if you perhaps know of another way this could be solved without needing to perform an instanceof check for every discarded object that might be a better route to explore.
From my limited experience the only thing I can think of is using e.g Mono.using()/Flux.using() when creating a Payload.

input.flatMap(bytes -> Mono.using(
    () -> ByteBufPayload.create(bytes),
    data -> ...,
    Payload::release
));

Kind regards,
Tom

[luczus]

Hi Oleh, @Svenskunganka!

I've created PR #1079 with a fix.
Please let me know what you think about these changes.

Best
Lukasz

[tukez]

I noticed the same problem and in my case at least the offending instance is of type org.springframework.core.io.buffer.NettyDataBuffer which holds a ByteBuf. Should the inner ByteBuf be released? That is not possible (other than reflection) in rsocket-java though?

[kmccarp]

@OlegDokuka are there any plans to integrate the changes made by @luczus? This is heavily polluting our logs.