Package io.streamthoughts.azkarra.api.events.reactive

Class AsyncMulticastEventStreamPublisher<K,V>

java.lang.Object

io.streamthoughts.azkarra.api.events.reactive.AsyncMulticastEventStreamPublisher<K,V>

All Implemented Interfaces:

EventStreamPublisher<K,V>, Flow.Publisher<KV<K,V>>

public class AsyncMulticastEventStreamPublisher<K,V>
extends Object
implements EventStreamPublisher<K,V>

The AsyncMulticastEventStreamPublisher is an implementation of Reactive Streams Flow.Publisher which executes asynchronously, using an internal single-thread Executor. Records are produced from a given EventStream in a "multicast" configuration to its Flow.Subscriber. Note: A subscriber will start receiving events from the head of the event-stream buffer, as soon as it perform a valid request demand. The publisher will continue to poll the event-stream buffer as long as at-least one subscriber is requesting more records, i.e even if other subscriptions are applying back-pressure.

Since:

0.8.0

Constructor Summary

Constructors

Constructor	Description
AsyncMulticastEventStreamPublisher(EventStream<K,V> stream)	Creates a new AsyncMulticastEventStreamPublisher instance.

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncMulticastEventStreamPublisher

public AsyncMulticastEventStreamPublisher(EventStream<K,V> stream)

Creates a new AsyncMulticastEventStreamPublisher instance.

Parameters:

stream - the EventStream.

Method Detail

type

public String type()

Get the event type name attached to this publisher.

Specified by:

type in interface EventStreamPublisher<K,V>

Returns:

the event type name.

subscribe

public void subscribe(Flow.Subscriber<? super KV<K,V>> subscriber)

Specified by:

subscribe in interface EventStreamPublisher<K,V>

Specified by:

subscribe in interface Flow.Publisher<K>