gRPC error handling

[pranjul tayal]

Hi,

I am implementing bidirectional reactive stream gRPC calls in spring boot which accepts Flux. 

If Flux sent from server has any error for a particular stream entity then at client side the connection gets broken and I am not able to see any result. RuntimeException occurs.

Is there any method in which we can filter out the error stream entities on client side in a flux.

Regards,

Pranjul Tayal