package jaxrs_client;

import javax.ws.rs.client.Client;
import javax.ws.rs.client.ClientBuilder;
import javax.ws.rs.core.GenericType;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import org.glassfish.jersey.client.ChunkedInput;
import org.glassfish.jersey.client.ClientConfig;

public class ChunkedInputTest {

    public static void main(String[] args) {
        
        Client client = ClientBuilder.newClient();
        
        final Response response = client.target("http://localhost:9090/jaxrs.prototype.tomcat7/rest/async/asynchronous").request(MediaType.APPLICATION_JSON).get();
        
        final ChunkedInput<String> chunkedInput =
                response.readEntity(new GenericType<ChunkedInput<String>>() {});
        
        String chunk = null;
        chunk = chunkedInput.read();
        while (chunk != null) {
            System.out.println("Next chunk received: " + chunk);
            chunk = chunkedInput.read();
        }
    }
    
}