yanglifan/spring-reactor-workshop

Demo for the reactive programming. Curently use Spring Reactor to show how to create a reactive app with REST APIs and the reactive data repositories.

spring-reactor-workshop's Issues

Create a demo to show how to chain reactive calls together

Learn Spring Reactor

Based on the following links:

• http://www.infoq.com/cn/articles/reactor-by-example
• https://projectreactor.io/docs/core/release/reference/
• https://github.com/reactor/lite-rx-api-hands-on/tree/master/src/main/java/io/pivotal/literx

Fix that the reactive Redis call is failed

Completed ex stack:

java.lang.IllegalStateException: COMPLETED
	at org.springframework.http.server.reactive.AbstractListenerReadPublisher$State.subscribe(AbstractListenerReadPublisher.java:313) ~[spring-web-5.0.0.BUILD-20161224.031522-513.jar:5.0.0.BUILD-SNAPSHOT]
	at org.springframework.http.server.reactive.AbstractListenerReadPublisher.subscribe(AbstractListenerReadPublisher.java:63) ~[spring-web-5.0.0.BUILD-20161224.031522-513.jar:5.0.0.BUILD-SNAPSHOT]
	at reactor.core.publisher.FluxSource.subscribe(FluxSource.java:59) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoReduce.subscribe(MonoReduce.java:43) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:64) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoOtherwise.subscribe(MonoOtherwise.java:44) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoOtherwiseIfEmpty.subscribe(MonoOtherwiseIfEmpty.java:44) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoDefaultIfEmpty.subscribe(MonoDefaultIfEmpty.java:37) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:85) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoWhen$MonoWhenCoordinator.subscribe(MonoWhen.java:155) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoWhen.subscribe(MonoWhen.java:121) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenMap.subscribe(MonoThenMap.java:55) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:78) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoOtherwise.subscribe(MonoOtherwise.java:44) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenMap$MonoThenApplyMain.onNext(MonoThenMap.java:132) [reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:990) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenIgnore$MonoThenIgnoreMain.drain(MonoThenIgnore.java:143) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenIgnore.subscribe(MonoThenIgnore.java:54) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenMap.subscribe(MonoThenMap.java:55) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenMap$MonoThenApplyMain.onNext(MonoThenMap.java:132) [reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:68) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:78) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:255) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:734) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:124) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:990) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenIgnore$MonoThenAcceptSubscriber.onNext(MonoThenIgnore.java:258) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:1613) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenIgnore$MonoThenAcceptSubscriber.onSubscribe(MonoThenIgnore.java:247) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:63) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenIgnore$MonoThenIgnoreMain.drain(MonoThenIgnore.java:149) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenIgnore$MonoThenIgnoreMain.ignoreDone(MonoThenIgnore.java:184) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoThenIgnore$MonoThenIgnoreSubscriber.onComplete(MonoThenIgnore.java:218) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.ReplayProcessor$SizeBoundReplayBuffer.replayNormal(ReplayProcessor.java:835) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.ReplayProcessor$SizeBoundReplayBuffer.replay(ReplayProcessor.java:927) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.ReplayProcessor.onComplete(ReplayProcessor.java:462) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoProcessor.drainLoop(MonoProcessor.java:489) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:323) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:86) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.ReplayProcessor$SizeBoundReplayBuffer.replayNormal(ReplayProcessor.java:844) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.ReplayProcessor$SizeBoundReplayBuffer.replay(ReplayProcessor.java:927) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.ReplayProcessor.onNext(ReplayProcessor.java:429) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoProcessor.drainLoop(MonoProcessor.java:488) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoProcessor.onNext(MonoProcessor.java:323) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:124) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:990) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at reactor.core.publisher.MonoReduce$AggregateSubscriber.onComplete(MonoReduce.java:118) ~[reactor-core-3.0.4.RELEASE.jar:3.0.4.RELEASE]
	at org.springframework.http.server.reactive.AbstractListenerReadPublisher$State.onAllDataRead(AbstractListenerReadPublisher.java:331) ~[spring-web-5.0.0.BUILD-20161224.031522-513.jar:5.0.0.BUILD-SNAPSHOT]
	at org.springframework.http.server.reactive.AbstractListenerReadPublisher.onAllDataRead(AbstractListenerReadPublisher.java:86) ~[spring-web-5.0.0.BUILD-20161224.031522-513.jar:5.0.0.BUILD-SNAPSHOT]
	at org.springframework.http.server.reactive.ServletServerHttpRequest$RequestBodyPublisher$RequestBodyPublisherReadListener.onAllDataRead(ServletServerHttpRequest.java:250) ~[spring-web-5.0.0.BUILD-20161224.031522-513.jar:5.0.0.BUILD-SNAPSHOT]
	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:361) ~[tomcat-embed-core-8.5.6.jar:8.5.6]
	at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:784) ~[tomcat-embed-core-8.5.6.jar:8.5.6]
	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) ~[tomcat-embed-core-8.5.6.jar:8.5.6]
	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:802) ~[tomcat-embed-core-8.5.6.jar:8.5.6]
	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1410) ~[tomcat-embed-core-8.5.6.jar:8.5.6]
	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) ~[tomcat-embed-core-8.5.6.jar:8.5.6]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) ~[na:1.8.0_65]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) ~[na:1.8.0_65]
	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) ~[tomcat-embed-core-8.5.6.jar:8.5.6]
	at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_65]

Move the code to new package

Move from com.github.yanglifan to com.github.yanglifan.demo.reactive