package com.bird;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.web.WebAppConfiguration;
import org.springframework.boot.test.SpringApplicationConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = SseventApplication.class)
@WebAppConfiguration
public class SseventApplicationTests {

	@Test
	public void contextLoads() {
	}

}

@@ -12,16 +12,168 @@
 .bird;%0A%0A
+import org.glassfish.jersey.media.sse.EventInput;%0Aimport org.glassfish.jersey.media.sse.InboundEvent;%0Aimport org.glassfish.jersey.media.sse.SseFeature;%0A
 import o
@@ -251,31 +251,35 @@
 ork.
-test.context.web.WebApp
+boot.test.SpringApplication
 Conf
@@ -320,120 +320,229 @@
 ork.
-boot.test.SpringApplicationConfiguration;%0Aimport org.springframework.test.context.junit4.SpringJUnit4ClassRunner
+test.context.junit4.SpringJUnit4ClassRunner;%0Aimport org.springframework.test.context.web.WebAppConfiguration;%0A%0Aimport javax.ws.rs.client.Client;%0Aimport javax.ws.rs.client.ClientBuilder;%0Aimport javax.ws.rs.client.WebTarget
 ;%0A%0A@
@@ -713,16 +713,22 @@
  %7B%0A%0A
-%09
+    
 @Test%0A
-%09
+    
 publ
@@ -756,9 +756,670 @@
 ) %7B%0A
-%09
+    %7D%0A%0A    @Test%0A    public void oneClient() %7B%0A        Client client = ClientBuilder.newBuilder()%0A                .register(SseFeature.class).build();%0A        WebTarget target = client.target(%22http://localhost:8080/events%22);%0A%0A        EventInput eventInput = target.request().get(EventInput.class);%0A        while (!eventInput.isClosed()) %7B%0A            final InboundEvent inboundEvent = eventInput.read();%0A            if (inboundEvent == null) %7B%0A                // connection has been closed%0A                break;%0A            %7D%0A            System.out.println(inboundEvent.getName() + %22; %22%0A                    + inboundEvent.readData(String.class));%0A        %7D%0A    
 %7D%0A%0A%7D

Add client to test