Package org.palladiosimulator.analyzer.slingshot.eventdriver.entity

Class Subscriber<T>

java.lang.Object

org.palladiosimulator.analyzer.slingshot.eventdriver.entity.Subscriber<T>

Type Parameters:

T - The event type

All Implemented Interfaces:

io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.functions.Consumer<T>, Comparable<Subscriber<T>>, InterceptorInformation

public class Subscriber<T>
extends Object
implements io.reactivex.rxjava3.functions.Consumer<T>, io.reactivex.rxjava3.disposables.Disposable, Comparable<Subscriber<T>>, InterceptorInformation

A subscriber to an event of type T that should be activated upon the event. It holds a reference to a EventHandler.

It also holds further information about

• A non-negative number priority (default is 0). Subscribers are compared based on its priority.
• An array of reified types.
• A name that identifies this subscriber.
• The event type itself (reified).
• The associated contracts to this subscriber.
• Optionally the enclosing type where the event handler is residing (i.e. if the event handler is a Java Method).
• Optionally Pre and Post interceptors specifically for this subscriber.

Regarding the comparison, it is only comparable to other subscribers of the same event!

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	Subscriber.Builder<T>

Method Summary

Modifier and Type	Method	Description
void	accept(T event)
void	addPostInterceptor(IPostInterceptor postInterceptor)
void	addPreInterceptor(IPreInterceptor preInterceptor)
static <T> Subscriber.Builder<T>	builder(Class<T> forEvent)	Creates builder to build Subscriber.
int	compareTo(Subscriber<T> other)
void	dispose()
boolean	equals(Object obj)
List<SubscriberContract>	getAssociatedContracts()
Optional<Class<?>>	getEnclosingType()
Class<T>	getEventType()
Class<?>	getHandlerType()
String	getName()
int	getPriority()
List<Class<?>>	getReifiedClasses()
int	hashCode()
boolean	isDisposed()

Methods inherited from class java.lang.Object

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

Method Details

accept

public void accept(T event)
            throws Throwable

Specified by:

accept in interface io.reactivex.rxjava3.functions.Consumer<T>

Throws:

Throwable

dispose

public void dispose()

Specified by:

dispose in interface io.reactivex.rxjava3.disposables.Disposable

isDisposed

public boolean isDisposed()

Specified by:

isDisposed in interface io.reactivex.rxjava3.disposables.Disposable

compareTo

public int compareTo(Subscriber<T> other)

Specified by:

compareTo in interface Comparable<T>

addPreInterceptor

public void addPreInterceptor(IPreInterceptor preInterceptor)

addPostInterceptor

public void addPostInterceptor(IPostInterceptor postInterceptor)

getPriority

public int getPriority()

getReifiedClasses

public List<Class<?>> getReifiedClasses()

getName

public String getName()

Specified by:

getName in interface InterceptorInformation

getHandlerType

public Class<?> getHandlerType()

Specified by:

getHandlerType in interface InterceptorInformation

getEnclosingType

public Optional<Class<?>> getEnclosingType()

Specified by:

getEnclosingType in interface InterceptorInformation

getEventType

public Class<T> getEventType()

Specified by:

getEventType in interface InterceptorInformation

getAssociatedContracts

public List<SubscriberContract> getAssociatedContracts()

Specified by:

getAssociatedContracts in interface InterceptorInformation

builder

public static <T> Subscriber.Builder<T> builder(Class<T> forEvent)

Creates builder to build Subscriber.

Returns:

created builder

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object