Package org.apache.pekko.event

Interface ScanningClassification

public interface ScanningClassification

Maps Classifiers to Subscribers and selects which Subscriber should receive which publication through scanning through all Subscribers through the matches(classifier, event) method

Note: the compareClassifiers and compareSubscribers must together form an absolute ordering (think java.util.Comparator.compare)

Method Summary

Modifier and Type	Method	Description
int	compareClassifiers(ScanningClassification a, ScanningClassification b)	Provides a total ordering of Classifiers (think java.util.Comparator.compare)
int	compareSubscribers(ScanningClassification a, ScanningClassification b)	Provides a total ordering of Subscribers (think java.util.Comparator.compare)
boolean	matches(ScanningClassification classifier, ScanningClassification event)	Returns whether the specified Classifier matches the specified Event
void	org$apache$pekko$event$ScanningClassification$_setter_$subscribers_$eq(ConcurrentSkipListSet<scala.Tuple2<Object,Object>> x$1)
void	publish(ScanningClassification event)
void	publish(ScanningClassification event, ScanningClassification subscriber)	Publishes the specified Event to the specified Subscriber
boolean	subscribe(ScanningClassification subscriber, ScanningClassification to)
ConcurrentSkipListSet<scala.Tuple2<Object,Object>>	subscribers()
void	unsubscribe(ScanningClassification subscriber)
boolean	unsubscribe(ScanningClassification subscriber, ScanningClassification from)

Method Details

compareClassifiers

int compareClassifiers(ScanningClassification a,
 ScanningClassification b)

Provides a total ordering of Classifiers (think java.util.Comparator.compare)

compareSubscribers

int compareSubscribers(ScanningClassification a,
 ScanningClassification b)

Provides a total ordering of Subscribers (think java.util.Comparator.compare)

matches

boolean matches(ScanningClassification classifier,
 ScanningClassification event)

Returns whether the specified Classifier matches the specified Event

org$apache$pekko$event$ScanningClassification$_setter_$subscribers_$eq

void org$apache$pekko$event$ScanningClassification$_setter_$subscribers_$eq(ConcurrentSkipListSet<scala.Tuple2<Object,Object>> x$1)

publish

void publish(ScanningClassification event,
 ScanningClassification subscriber)

Publishes the specified Event to the specified Subscriber

publish

void publish(ScanningClassification event)

subscribe

boolean subscribe(ScanningClassification subscriber,
 ScanningClassification to)

subscribers

ConcurrentSkipListSet<scala.Tuple2<Object,Object>> subscribers()

unsubscribe

boolean unsubscribe(ScanningClassification subscriber,
 ScanningClassification from)

unsubscribe

void unsubscribe(ScanningClassification subscriber)