@Singleton @Requires(beans=RoutesEndpoint.class) public class RxJavaRouteDataCollector extends Object implements RouteDataCollector<Map<String,Object>>
Constructor and Description |
---|
RxJavaRouteDataCollector(RouteData routeData,
ExecutorService executorService) |
Modifier and Type | Method and Description |
---|---|
Publisher<Map<String,Object>> |
getData(Stream<UriRoute> routes) |
protected String |
getRouteKey(UriRoute route) |
public RxJavaRouteDataCollector(RouteData routeData, @Named(value="io") ExecutorService executorService)
routeData
- The RouteDataexecutorService
- The executor service