import org.onap.dcae.collectors.veshv.model.CollectorConfiguration
import org.onap.dcae.collectors.veshv.model.RoutedMessage
- import org.onap.dcae.collectors.veshv.model.VesMessage
import reactor.core.publisher.Flux
interface Sink {
interface ConfigurationProvider {
operator fun invoke(): Flux<CollectorConfiguration>
-
- companion object {
- fun from(function: () -> Flux<CollectorConfiguration>): ConfigurationProvider =
- object : ConfigurationProvider {
- override fun invoke(): Flux<CollectorConfiguration> = function()
- }
- }
}