Flattening the project structure - now demos are available directly a…

…t top level

.gitignore

@@ -1,22 +1,26 @@
-# Compiled class file
-*.class
+.gradle
+build/
+out/
+!gradle/wrapper/gradle-wrapper.jar
 
-# Log file
-*.log
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
 
-# BlueJ files
-*.ctxt
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
 
-# Mobile Tools for Java (J2ME)
-.mtj.tmp/
-
-# Package Files #
-*.jar
-*.war
-*.ear
-*.zip
-*.tar.gz
-*.rar
-
-# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
-hs_err_pid*
+### NetBeans ###
+nbproject/private/
+build/
+nbbuild/
+dist/
+nbdist/
+.nb-gradle/

hello-webflux/reactive-quotes/src/main/java/org/iproduct/demos/spring/reactivequotes/domain/Quote.java → reactive-quotes/src/main/java/org/iproduct/demos/spring/reactivequotes/domain/Quote.java

@@ -15,7 +15,6 @@
 @AllArgsConstructor
 @EqualsAndHashCode(of = {"id"})
 @ToString
-@Builder
 public class Quote {
 
     private static long nextId = 0;

reactive-quotes/src/main/java/org/iproduct/demos/spring/reactivequotes/handlers/ReactiveQuotesHandler.java

@@ -0,0 +1,37 @@
+package org.iproduct.demos.spring.reactivequotes.handlers;
+
+import lombok.extern.slf4j.Slf4j;
+import org.iproduct.demos.spring.reactivequotes.domain.Quote;
+import org.iproduct.demos.spring.reactivequotes.services.QuotesGenerator;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.ServerResponse;
+import reactor.core.publisher.Mono;
+
+import java.time.Duration;
+
+import static org.springframework.http.MediaType.APPLICATION_STREAM_JSON;
+import static org.springframework.http.MediaType.TEXT_EVENT_STREAM;
+
+@Component
+@Slf4j
+public class ReactiveQuotesHandler {
+
+    @Autowired
+    private QuotesGenerator generator;
+
+
+    public Mono<ServerResponse> streamQuotes(ServerRequest request) {
+        return ServerResponse.ok()
+                .contentType(APPLICATION_STREAM_JSON)
+                .body(generator.getQuoteStream(Duration.ofMillis(250)), Quote.class);
+    }
+
+    public Mono<ServerResponse> streamQuotesSSE(ServerRequest request) {
+        return ServerResponse.ok()
+                .contentType(TEXT_EVENT_STREAM)
+                .body(generator.getQuoteStream(Duration.ofMillis(250)), Quote.class);
+    }
+
+}

settings.gradle

@@ -0,0 +1,4 @@
+include 'reactive-quotes'
+include 'webflux-users'
+include 'quotes-demo-app'
+

webflux-users/src/main/resources/application.properties

@@ -0,0 +1,3 @@
+server.port: 8080
+endpoints.sensitive=false
+endpoints.metrics.enabled=true