HeadlineClient

HeadlineClient.java

package com.foo.http.client;

import io.micronaut.http.MediaType;
import io.micronaut.http.annotation.Get;
import io.micronaut.http.client.annotation.Client;
import io.reactivex.Flowable;
import reactor.core.publisher.Flux;

@Client("/streaming")
public interface HeadlineClient {
    @Get(value = "/headlines", processes = MediaType.APPLICATION_JSON_STREAM) 
    Flowable<Headline> streamHeadlines();
}