Package dev.getelements.elements.sdk.util

Class LinkedPublisher<T>

java.lang.Object

dev.getelements.elements.sdk.util.AbstractPublisher<T>

dev.getelements.elements.sdk.util.LinkedPublisher<T>

Type Parameters:

T - the type of event to publish

All Implemented Interfaces:

Publisher<T>, Iterable<Object>

public class LinkedPublisher<T>
extends AbstractPublisher<T>
implements Iterable<Object>

A non-threadsafe publisher which tracks subscribers in a linked list. For the purposes of debugging this implements Iterable which most IDEs will recognize and render as sequence in the debugger.

Field Summary

Fields inherited from class dev.getelements.elements.sdk.util.AbstractPublisher

logger

Constructor Summary

Constructors

Constructor	Description
LinkedPublisher()
LinkedPublisher(org.slf4j.Logger logger)

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears all Subscriptions and implicitly removes them from the internal pool.
Iterator<Object>	iterator()	Used only to facilitate debugging.
void	publish(T t, Consumer<? super T> onFinish, Consumer<Throwable> onException)	Publishes the supplied event synchronously and calls the Consumer when all Subscriptions have been notified.
Subscription	subscribe(BiConsumer<Subscription,? super T> consumer)	Subscribes to a particular event.

Methods inherited from class dev.getelements.elements.sdk.util.AbstractPublisher

handleException, logException, publish, publish

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface dev.getelements.elements.sdk.util.Publisher

subscribe

Constructor Details

LinkedPublisher

public LinkedPublisher()

LinkedPublisher

public LinkedPublisher(org.slf4j.Logger logger)

Method Details

subscribe

public Subscription subscribe(BiConsumer<Subscription,? super T> consumer)

Description copied from interface: Publisher

Subscribes to a particular event. The supplied BiConsumer will receive zero or more events in the future until the associated call to Subscription.unsubscribe().

Specified by:

subscribe in interface Publisher<T>

Parameters:

consumer - the BiConsumer which will accept event

Returns:

the Subscription

clear

public void clear()

Description copied from interface: Publisher

Clears all Subscriptions and implicitly removes them from the internal pool. Implementing this interface method is optional, and therefore this may throw an instance of UnsupportedOperationException.

Specified by:

clear in interface Publisher<T>

publish

public void publish(T t,
 Consumer<? super T> onFinish,
 Consumer<Throwable> onException)

Description copied from interface: Publisher

Publishes the supplied event synchronously and calls the Consumer when all Subscriptions have been notified. Additionally, this notifies for every exception thrown in the process.

Specified by:

publish in interface Publisher<T>

Parameters:

t - the event

onFinish - the Consumer to be called after all Subscriptions have been notified

onException - the Consumer which is notified for each exception thrown

iterator

public Iterator<Object> iterator()

Used only to facilitate debugging. The returned Objects are internal implementation details and not intended to be used to execute business logic of the application.

Specified by:

iterator in interface Iterable<T>

Returns:

an Iterator over the subscribers.