monkey-codes / java-reactive-chat

A Simple Chat App using WebFlux (Reactive Streams), WebSockets and a React frontend.

WebFlux Chat App

Sample code accompanying How To Build a Chat App Using WebFlux, WebSockets & React.

java-reactive-chat's Issues

socket handler blocking call -> subscribe

Hey monkey-codes,
you're calling subscribe in a non-blocking code..

please fix it

Need explanation

Can you please explain how the zipWith is working in this line
.zipWith(session.send(outputEvents.map(session::textMessage)))

Need Help

Hey @monkey-codes ,

Sometime back u=you had posted question on github https://stackoverflow.com/questions/51608881/webflux-websocket-send-to-specific-session-id, were you able to figure out the solution for this?
If yes, could you please let us know as well.

A problem with running the application

Hi,

Thank you for your sharing.

Using Windows 10, I followed your build instruction. and both of "node" and "npm" are installed as follows:
$ npm -version
4.1.2
$ node -v
v7.7.1

when I want to build the app, I encountered the following error:

gradlew clean build

THIS BUILD HAS BEEN TESTED ON OSX WITH NPM 4.1.2 AND NODE v7.7.1 AVAILABLE ON THE PATH

---

:clean
:compileJava
Note: E:\IdeaProjects\Monem\java-reactive-chat-master\java-reactive-chat-master\src\main\java\codes\monkey\reactivechat\UserStats.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
:npmDependencies FAILED

FAILURE: Build failed with an exception.

• What went wrong:
  Execution failed for task ':npmDependencies'.

A problem occurred starting process 'command 'npm''

• Try:
  Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output.

BUILD FAILED

Total time: 4.827 secs

It would be appreciative if you help me solving this problem.
Thanks.