fix formatting

johnmcclean · johnmcclean · commit 32b8a6a412f9 · 2017-05-15T12:25:48.000+01:00
diff --git a/micro-grizzly-with-jersey/src/test/java/app/publisher/binder/direct/AsyncPublisherTest.java b/micro-grizzly-with-jersey/src/test/java/app/publisher/binder/direct/AsyncPublisherTest.java
@@ -18,29 +18,30 @@
 
 @Microserver
 public class AsyncPublisherTest {
-	RestAgent rest = new RestAgent();
-	MicroserverApp server;
-	@Before
-	public void startServer(){
-		
-			server = new MicroserverApp(()->"binder");
-		server.start();
-
-	}
-	
-	@After
-	public void stopServer(){
-		server.stop();
-	}
-	
-	@Test
-	public void runAppAndBasicTest() throws InterruptedException, ExecutionException{
-		
-		
-		//DirectMyIncovationHandler.captured=false;
-		assertThat(rest.get("http://localhost:8080/binder/test"),is("hello world!"));
-		//assertTrue(DirectMyIncovationHandler.captured);
-		
-		
-	}
+    RestAgent rest = new RestAgent();
+    MicroserverApp server;
+
+    @Before
+    public void startServer() {
+
+        server = new MicroserverApp(() -> "binder");
+        server.start();
+
+    }
+
+    @After
+    public void stopServer() {
+        server.stop();
+    }
+
+    @Test
+    public void runAppAndBasicTest() throws InterruptedException, ExecutionException {
+
+
+        //DirectMyIncovationHandler.captured=false;
+        assertThat(rest.get("http://localhost:8080/binder/test"), is("hello world!"));
+        //assertTrue(DirectMyIncovationHandler.captured);
+
+
+    }
 }
diff --git a/micro-grizzly-with-jersey/src/test/java/app/publisher/binder/direct/AsyncResource.java b/micro-grizzly-with-jersey/src/test/java/app/publisher/binder/direct/AsyncResource.java
@@ -15,25 +15,26 @@
 @Path("/test")
 public class AsyncResource {
 
-	private void sleep(){
+    private void sleep() {
         try {
             Thread.sleep(10000);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
     }
 
-	@GET
-	public Future<String> myEndPoint(){
-		return Future.ofSupplier(()->{
+    @GET
+    public Future<String> myEndPoint() {
+        return Future.ofSupplier(() -> {
             sleep();
-			return "hello world!";
-		}, Executors.newFixedThreadPool(1));
-	}
+            return "hello world!";
+        }, Executors.newFixedThreadPool(1));
+    }
+
     @GET
-    public ReactiveSeq<String> async2(){
-        return Spouts.publishOn(Stream.of("hello"),Executors.newFixedThreadPool(1));
+    public ReactiveSeq<String> async2() {
+        return Spouts.publishOn(Stream.of("hello"), Executors.newFixedThreadPool(1));
     }
 
-	
+
 }
