Package io.streamthoughts.azkarra.http.sse

Class ServerSentEventSubscriber<K,V>

java.lang.Object

io.streamthoughts.azkarra.http.sse.ServerSentEventSubscriber<K,V>

Type Parameters:

K - the record-key type

V - the record-value type.

All Implemented Interfaces:

Flow.Subscriber<KV<K,V>>

public class ServerSentEventSubscriber<K,V>
extends Object
implements Flow.Subscriber<KV<K,V>>

A subscriber that sent published KV records over HTTP using a Server-Sent Event (SSE) connection.

Since:

0.8.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ServerSentEventSubscriber.StreamedEvent

Constructor Summary

Constructors

Constructor	Description
ServerSentEventSubscriber(io.undertow.server.handlers.sse.ServerSentEventConnection connection, String eventType, String applicationId, Json json)	Creates a new ServerSentEventSubscriber instance.

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable throwable)
void	onNext(KV<K,V> record)
void	onSubscribe(Flow.Subscription subscription)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerSentEventSubscriber

public ServerSentEventSubscriber(io.undertow.server.handlers.sse.ServerSentEventConnection connection,
                                 String eventType,
                                 String applicationId,
                                 Json json)

Creates a new ServerSentEventSubscriber instance.

Parameters:

connection - the ServerSentEventConnection.

eventType - the event type.

applicationId - the application.id of KafkaStreams, used for logging.

json - the Json serializer.

Method Detail

onSubscribe

public void onSubscribe(Flow.Subscription subscription)

Specified by:

onSubscribe in interface Flow.Subscriber<K>

onNext

public void onNext(KV<K,V> record)

Specified by:

onNext in interface Flow.Subscriber<K>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface Flow.Subscriber<K>

onComplete

public void onComplete()

Specified by:

onComplete in interface Flow.Subscriber<K>