Class ReactiveInfoAggregator
java.lang.Object
io.micronaut.management.endpoint.info.impl.ReactiveInfoAggregator
- All Implemented Interfaces:
InfoAggregator<Map<String,
Object>>
@Singleton
@Requires(beans=InfoEndpoint.class)
public class ReactiveInfoAggregator
extends Object
implements InfoAggregator<Map<String,Object>>
Default implementation of InfoAggregator
.
- Since:
- 1.0
- Author:
- James Kleeh, Zachary Klein
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionaggregate
(InfoSource[] sources) Aggregate an array ofInfoSource
and return a publisher.protected reactor.core.publisher.Flux<Map.Entry<Integer,
PropertySource>> aggregateResults
(InfoSource[] sources)
-
Constructor Details
-
ReactiveInfoAggregator
public ReactiveInfoAggregator()
-
-
Method Details
-
aggregate
Description copied from interface:InfoAggregator
Aggregate an array ofInfoSource
and return a publisher. -
aggregateResults
protected reactor.core.publisher.Flux<Map.Entry<Integer,PropertySource>> aggregateResults(InfoSource[] sources) - Parameters:
sources
- Array ofInfoSource
- Returns:
- An
Flux
ofMap.Entry
, where the key is anInteger
and value is thePropertySource
returned by theInfoSource
-