public Mono < ServiceMessage > invokeOne ( ServiceMessage message , BiFunction < ServiceMessage , Class < ? > , ServiceMessage > dataDecoder ) { return Mono . defer ( ( ) -> Mono . from ( invoke ( toRequest ( message , dataDecoder ) ) ) ) . map ( this :: toResponse ) . onErrorResume ( throwable -> Mono . just ( errorMapper . toMessage ( throwable ) ) ) ; }
Invokes service method with single response .