3

Mono現在のマイルストーン (M4) のドキュメントには、 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)));

text/event-streamWebClient を使用して(を返すサービスから) ストリーミングされたデータを Flux に取得するにはどうすればよいですか? 自動ジャクソン変換をサポートしていますか?

これは以前のマイルストーンで行った方法ですが、API が変更されており、それを行う方法が見つかりません。

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

2 に答える 2

7

これは、新しい API で同じことを実現する方法です。

final ClientRequest request = ClientRequest.GET(url)
        .accept(MediaType.TEXT_EVENT_STREAM).build();
Flux<Alert> alerts = webClient.exchange(request)
        .retrieve().bodyToFlux(Alert.class);
于 2017-01-07T16:34:51.723 に答える