Package io.streamthoughts.azkarra.api.events.reactive
-
Interface Summary Interface Description EventStreamPublisher<K,V> The main publisher interface to subscribe to a specific streams of key-value records. -
Class Summary Class Description AsyncMulticastEventStreamPublisher<K,V> The AsyncMulticastEventStreamPublisher is an implementation of Reactive StreamsFlow.Publisher
which executes asynchronously, using an internal single-threadExecutor
.