Import as gradle project using java 1.8
Make sure your intellij Java level set to 8 - Lambdas (required for lambdas to work)
Example 1 : Simple Observable on interval
SimpleIntervalServer run main()
Example 2 : Stock Observable and Flowable
StockServerExample run main()
Example 3: Full fledged example of a event based reactive architecture running on cluster passing msg between 3 different services
SockJsServer run main() Appointment run main() Inventory run main () (Order not important . Beauty of async messaging)
open index.html in browser to see the msgs