Spring 5 Web Reactive - How can we use WebClient to retrieve streamed data in a Flux?

Question

The current milestone (M4) documentation shows and example about how to retrieve a Mono using WebClient:

WebClient webClient = WebClient.create(new ReactorClientHttpConnector());

ClientRequest<Void> request = ClientRequest.GET("http://example.com/accounts/{id}", 1L)
                .accept(MediaType.APPLICATION_JSON).build();

Mono<Account> account = this.webClient
                .exchange(request)
                .then(response -> response.body(toMono(Account.class)));

How can we get streamed data (from a service that returns text/event-stream) into a Flux using WebClient? Does it support automatic Jackson conversion?.

This is how I did it in a previous milestone, but the API has changed and can't find how to do it anymore:

final ClientRequest<Void> request = ClientRequest.GET(url)
    .accept(MediaType.TEXT_EVENT_STREAM).build();
Flux<Alert> response = webClient.retrieveFlux(request, Alert.class)

Current milestone is M4... So you might want to check the documentation again, a lot of work has been done in the M4 release to complete the reactive features. — M. Deinum
– M. Deinum, Commented Dec 30, 2016 at 18:37
I have checked it and even the current snapshot but no details about this. — codependent
– codependent, Commented Dec 30, 2016 at 20:45
I checked Spring Framework 5 RC3 and it seems that ClientRequest doesn't have GET method now — Sergiy
– Sergiy, Commented Aug 3, 2017 at 18:15

Brian Clozel · Accepted Answer · 2018-06-13 15:26:25Z

8

This is how you can achieve the same thing with the new API:

final ClientRequest request = ClientRequest.GET(url)
        .accept(MediaType.TEXT_EVENT_STREAM).build();
Flux<Alert> alerts = webClient.exchange(request)
        .retrieve().bodyToFlux(Alert.class);

edited Jun 13, 2018 at 15:26

answered Jan 7, 2017 at 16:34

Brian Clozel

59.7k15 gold badges180 silver badges184 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Chandresh Mishra Over a year ago

I think there is no retrieve() with exchange

codependent · Accepted Answer · 2017-09-29 07:44:50Z

7

With Spring 5.0.0.RELEASE this is how you do it:

public Flux<Alert> getAccountAlerts(int accountId){
    String url = serviceBaseUrl+"/accounts/{accountId}/alerts";
    Flux<Alert> alerts = webClient.get()
        .uri(url, accountId)
        .accept(MediaType.APPLICATION_JSON)
        .retrieve()
        .bodyToFlux( Alert.class )
        .log();
    return alerts;
}

edited Sep 29, 2017 at 7:44

answered Aug 4, 2017 at 9:16

codependent

24.7k39 gold badges196 silver badges353 bronze badges

Collectives™ on Stack Overflow

Spring 5 Web Reactive - How can we use WebClient to retrieve streamed data in a Flux?

2 Answers 2

1 Comment

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

1 Comment

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related