Package org.apache.pekko.event
Interface LookupClassification
-
public interface LookupClassification
Maps Subscribers to Classifiers using equality on Classifier to store a Set of Subscribers (hence the need for compareSubscribers) Maps Events to Classifiers through the classify-method (so it knows who to publish to)The compareSubscribers need to provide a total ordering of the Subscribers
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description LookupClassification
classify(LookupClassification event)
Returns the Classifier associated with the given Eventint
compareSubscribers(LookupClassification a, LookupClassification b)
Provides a total ordering of Subscribers (think java.util.Comparator.compare)int
mapSize()
This is a size hint for the number of Classifiers you expect to have (use powers of 2)void
org$apache$pekko$event$LookupClassification$_setter_$subscribers_$eq(Index<java.lang.Object,java.lang.Object> x$1)
void
publish(LookupClassification event)
void
publish(LookupClassification event, LookupClassification subscriber)
Publishes the given Event to the given Subscriberboolean
subscribe(LookupClassification subscriber, LookupClassification to)
Index<java.lang.Object,java.lang.Object>
subscribers()
void
unsubscribe(LookupClassification subscriber)
boolean
unsubscribe(LookupClassification subscriber, LookupClassification from)
-
-
-
Method Detail
-
classify
LookupClassification classify(LookupClassification event)
Returns the Classifier associated with the given Event
-
compareSubscribers
int compareSubscribers(LookupClassification a, LookupClassification b)
Provides a total ordering of Subscribers (think java.util.Comparator.compare)
-
mapSize
int mapSize()
This is a size hint for the number of Classifiers you expect to have (use powers of 2)
-
org$apache$pekko$event$LookupClassification$_setter_$subscribers_$eq
void org$apache$pekko$event$LookupClassification$_setter_$subscribers_$eq(Index<java.lang.Object,java.lang.Object> x$1)
-
publish
void publish(LookupClassification event, LookupClassification subscriber)
Publishes the given Event to the given Subscriber
-
publish
void publish(LookupClassification event)
-
subscribe
boolean subscribe(LookupClassification subscriber, LookupClassification to)
-
subscribers
Index<java.lang.Object,java.lang.Object> subscribers()
-
unsubscribe
boolean unsubscribe(LookupClassification subscriber, LookupClassification from)
-
unsubscribe
void unsubscribe(LookupClassification subscriber)
-
-