Class SubscriptionManager<T extends Identified & Serializable>

java.lang.Object

co.yellowdog.platform.clients.serversentevents.SubscriptionManager<T>

All Implemented Interfaces:

AutoCloseable

public class SubscriptionManager<T extends Identified & Serializable>
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
SubscriptionManager(BiFunction<String,SubscriptionEventListener<T>,Subscription<T>> subscriptionProvider)

Method Summary

Modifier and Type	Method	Description
void	addListener(@NonNull String id, @NonNull SubscriptionEventListener<T> listener)
void	close()	Cancels any active Server-Sent Event subscriptions.
void	removeListener(@NonNull SubscriptionEventListener<T> listener)

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionManager

public SubscriptionManager(BiFunction<String,SubscriptionEventListener<T>,Subscription<T>> subscriptionProvider)

Method Details

addListener

public void addListener(@NonNull
 @NonNull String id,
 @NonNull
 @NonNull SubscriptionEventListener<T> listener)

removeListener

public void removeListener(@NonNull
 @NonNull SubscriptionEventListener<T> listener)

close

public void close()

Cancels any active Server-Sent Event subscriptions.

Specified by:

close in interface AutoCloseable