-
Notifications
You must be signed in to change notification settings - Fork 8
Next steps chatter
Saving feedback and suggestions from smart people.
April 5th, 2016
Drew:
that looks great!
I've been using Ember.js for front-end stuff and the way the promises work is nice.
It's nice to have that in Java can you only use that stuff with qbit?
Rick:
that stuff is based on what exists in QBit 1. I am coming up with QBit 2 and a
new IO lib based on Netty called Connekt. QBit 2 and Connekt will use Reakt.
QBit 1 has something very similar.
Rick:
I am glad you like it. That was my 10th try on the Promise implementation.
We kept writing it and throwing it away. We finally came up with something we liked.
Rick:
there will be an adapter for QBit 1
Rick:
My idea is reakt, reakt-util, reakt-rxjava, reakt-reactive-streams, etc.
and QBit 1 will have built-in support. QBit 2 will use reakt callbacks
instead of its own. As will conekt.
April 5th, 2016
Justin [12:36 PM]
cool
Rick [12:39 PM]
This mostly just provides the interfaces not the implementations.
There are some starter implementations but the idea is that anyone can implement this.
It is all about interfaces.
There will be adapters for Vertx, RxJava, Reactive Streams,
Guava Async Futures, etc.
Justin [12:47 PM]
If you're going to add streams, the clojure functions have a ton:
map, filter, keep, reduce, reductions, partition, interleave, zip etc
[12:47]
some of them are handy
Rick [12:49 PM]
so I have streams, and I want to add those.. I even know what some of
them mean. :simple_smile: My idea is reakt, reakt-util, reakt-rxjava,
reakt-reactive-streams, etc.
[12:50]
reakt-util would have map, filter, keep, reduce, reductions, partition,
interleave, zip ... so it builds on stream and adds those features to it.
Justin [12:50 PM]
well if you can take a stream and map it, or combine two streams into another stream
Rick [12:50 PM]
I want to keep reakt really really really small
[12:51]
yes I want to do that.
[12:54]
Expected has filter, and map. Expected is like Optional in Java or Option in Scala.
My crazy idea is to produce a Java stream from a Reakt stream.
https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html
or something like it.
Java Promises
- Promise
- Promise then*() and catchError()
- Promise thenMap()
- Promise all()
- Promise any()
- Blocking Promise
- Invokable Promise
- Reactor Replay Promises
Reactor, Stream, Results
- QBit Reactive Microservices
- Reakt Reactive Java
- Reakt Guava Bridge
- QBit Extensions
- Elekt Consul Leadership election
- Elekt Leadership election
- Reactive Microservices
What is Microservices Architecture?
QBit Java Micorservices lib tutorials
The Java microservice lib. QBit is a reactive programming lib for building microservices - JSON, HTTP, WebSocket, and REST. QBit uses reactive programming to build elastic REST, and WebSockets based cloud friendly, web services. SOA evolved for mobile and cloud. ServiceDiscovery, Health, reactive StatService, events, Java idiomatic reactive programming for Microservices.
Reactive Programming, Java Microservices, Rick Hightower
Java Microservices Architecture
[Microservice Service Discovery with Consul] (http://www.mammatustech.com/Microservice-Service-Discovery-with-Consul)
Microservices Service Discovery Tutorial with Consul
[Reactive Microservices] (http://www.mammatustech.com/reactive-microservices)
[High Speed Microservices] (http://www.mammatustech.com/high-speed-microservices)
Reactive Microservices Tutorial, using the Reactor
QBit is mentioned in the Restlet blog
All code is written using JetBrains Idea - the best IDE ever!
Kafka training, Kafka consulting, Cassandra training, Cassandra consulting, Spark training, Spark consulting
Java Promises
- Promise
- Promise then*() and catchError()
- Promise thenMap()
- Promise all()
- Promise any()
- Blocking Promise
- Invokable Promise
- Reactor Replay Promises
Callback, and async Results
Reactor, Stream and Stream Result
Expected & Circuit Breaker
Scala Akka and Reakt