使用Micronaut声明性客户端从可流动响应中获取标头

import io.micronaut.http.annotation.Get;
import io.micronaut.http.annotation.Header;
import io.micronaut.http.annotation.Headers;
import io.micronaut.http.client.annotation.Client;
import io.reactivex.Flowable;

@Client("http://remote-service-url")
public interface RemoteServiceClient {

    @Get("/endpoint")
    Flowable<String> getResponseWithHeaders();

}

@Get("/endpoint")
Flowable<String> getResponseWithHeaders(@Header("header-name") String headerValue);

import io.micronaut.runtime.Micronaut;

import javax.inject.Inject;

public class Application {

    @Inject
    private RemoteServiceClient remoteServiceClient;

    public static void main(String[] args) {
        Micronaut.run(Application.class);
    }

    public void someMethod() {
        Flowable<String> response = remoteServiceClient.getResponseWithHeaders();
        // 处理响应
    }
}