Interface EventStreamPublisher<K,V>
-
- Type Parameters:
K
- the record key type.V
- the record value type.
- All Superinterfaces:
Flow.Publisher<KV<K,V>>
- All Known Implementing Classes:
AsyncMulticastEventStreamPublisher
public interface EventStreamPublisher<K,V> extends Flow.Publisher<KV<K,V>>
The main publisher interface to subscribe to a specific streams of key-value records.- Since:
- 0.8.0
- See Also:
EventStream
,EventStreamProvider
,BlockingRecordQueue
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
subscribe(Flow.Subscriber<? super KV<K,V>> subscriber)
String
type()
Get the event type name attached to this publisher.
-
-
-
Method Detail
-
type
String type()
Get the event type name attached to this publisher.- Returns:
- the event type name.
-
subscribe
void subscribe(Flow.Subscriber<? super KV<K,V>> subscriber)
- Specified by:
subscribe
in interfaceFlow.Publisher<K>
-
-