Package dev.getelements.elements.sdk.util

Class ConcurrentDequePublisher<T>

java.lang.Object

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

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

Type Parameters:

T -

All Implemented Interfaces:

Publisher<T>, Iterable<Subscription>

public class ConcurrentDequePublisher<T>
extends AbstractPublisher<T>
implements Iterable<Subscription>

A thread-safe Publisher which uses a standard ConcurrentLinkedDeque to perform operations. When iterating the list of subscribers (such as when dispatching events) no locks are required as iteration of the list can happen without any locks. The iterator is weakly consistent as per the implementation of of ConcurrentLinkedDeque and unsubscription happens in O(n) (worst case).

Field Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
ConcurrentDequePublisher()
ConcurrentDequePublisher(Class<?> cls)
ConcurrentDequePublisher(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<Subscription>	iterator()
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

ConcurrentDequePublisher

public ConcurrentDequePublisher()

ConcurrentDequePublisher

public ConcurrentDequePublisher(Class<?> cls)

ConcurrentDequePublisher

public ConcurrentDequePublisher(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<Subscription> iterator()

Specified by:

iterator in interface Iterable<T>