Package org.apache.pekko.event

Interface SubchannelClassification

All Known Implementing Classes:

EventStream

public interface SubchannelClassification

Classification which respects relationships between channels: subscribing to one channel automatically and idempotently subscribes to all sub-channels.

Method Summary

Modifier and Type	Method	Description
void	addToCache(scala.collection.immutable.Seq<scala.Tuple2<Object,scala.collection.immutable.Set<Object>>> changes)
void	cache_$eq(scala.collection.immutable.Map<Object,scala.collection.immutable.Set<Object>> x$1)
SubchannelClassification	classify(SubchannelClassification event)	Returns the Classifier associated with the given Event
boolean	hasSubscriptions(SubchannelClassification subscriber)	INTERNAL API Expensive call! Avoid calling directly from event bus subscribe / unsubscribe.
void	publish(SubchannelClassification event)
void	publish(SubchannelClassification event, SubchannelClassification subscriber)	Publishes the given Event to the given Subscriber
void	removeFromCache(scala.collection.immutable.Seq<scala.Tuple2<Object,scala.collection.immutable.Set<Object>>> changes)
Subclassification<Object>	subclassification()	The logic to form sub-class hierarchy
boolean	subscribe(SubchannelClassification subscriber, SubchannelClassification to)
void	unsubscribe(SubchannelClassification subscriber)
boolean	unsubscribe(SubchannelClassification subscriber, SubchannelClassification from)

Method Details

addToCache

void addToCache(scala.collection.immutable.Seq<scala.Tuple2<Object,scala.collection.immutable.Set<Object>>> changes)

cache_$eq

void cache_$eq(scala.collection.immutable.Map<Object,scala.collection.immutable.Set<Object>> x$1)

classify

SubchannelClassification classify(SubchannelClassification event)

Returns the Classifier associated with the given Event

hasSubscriptions

boolean hasSubscriptions(SubchannelClassification subscriber)

INTERNAL API Expensive call! Avoid calling directly from event bus subscribe / unsubscribe.

publish

void publish(SubchannelClassification event,
 SubchannelClassification subscriber)

Publishes the given Event to the given Subscriber

publish

void publish(SubchannelClassification event)

removeFromCache

void removeFromCache(scala.collection.immutable.Seq<scala.Tuple2<Object,scala.collection.immutable.Set<Object>>> changes)

subclassification

Subclassification<Object> subclassification()

The logic to form sub-class hierarchy

subscribe

boolean subscribe(SubchannelClassification subscriber,
 SubchannelClassification to)

unsubscribe

boolean unsubscribe(SubchannelClassification subscriber,
 SubchannelClassification from)

unsubscribe

void unsubscribe(SubchannelClassification subscriber)