Stephane Maldini
Stephane Maldini
We followed the same API guidelines than reactor and transitively functional API especially rx. Would you think that Flux.map() directly maps something ? or Flux.merge(a, b) ? The consistency you...
Hey @dantesun , throwing in the subscribe might not work here because there is no more handler downstream to pass the error to (and it will bubble up internally due...
In this sample you are starting 1234 parallel request immediately you cannot expect the same latency as if you run one by one. Did you try to do block() instead...
I'd be interested to compare we are reworking the internals as well as the API. Can you share the code with the other netty solution? Other than that one item...
I was thinking that we could provide an accessor like "isHot" that is abstract on Flux and delegate to the source. Cold factories would return false and Processor/Publish etc return...
We do have it for core https://codecov.io/gh/reactor/reactor-core
great stuff @cbornet would love to see how we can plug in the lite cousin of rx especially for direct interop with spring fmk 5/spring boot 2
Looking forward to it for my next demos :D On Wed, Oct 29, 2014 at 5:23 PM, Ben Christensen [email protected] wrote: > 0.2.0 is released on BinTray ( > https://bintray.com/reactivex/RxJava/RxJavaReactiveStreams/0.2.0/view)...
@rkuhn can you use this repo: maven { url "http://oss.jfrog.org/repo" } ? can't remember for sure but I think this is where goes all the ratpack snapshots. BTW if you...
@rkuhn Having some hard time configuring the sample build into an IDEA project :(