reactive-geocoder
reactive-geocoder copied to clipboard
- Updated and organized the imports;
- Refactored the methods in LocationService;
- Updated Spring Boot version to 1.2.1.RELEASE;
- Adjusted some config methods.
Hey Tiarê, I was working in the same changes last night. I did a few different things that you did though
My locationEventStream
method is as follow:
@Bean
public Broadcaster<Location> locationEventStream(Environment env) {
return Streams.broadcast(env.get());
}
on findOne
and update
methods I used Environment.get()
instead of Environment.cachedDispatcher()
and I also changed the ratpack version to 0.9.11
@thiagogcm i agree with your observation, the only thing that i'll be checking is about the bean definition, as you can see by the picture bellow i don't have access to the method broadcast() on the class Streams.
i sent a parcial change with your comments.
I was checking here and the method broadcast() is not static. https://github.com/reactor/reactor/blob/master/reactor-core/src/main/java/reactor/rx/Stream.java#L306-L308
I'm not sure that this usage "Broadcaster.create()" is the better way to define this bean, i'm open for more opinion.
That's weird.. I checked the API and it's static
I'm working with M2 build since I couldn't find the RC1 API