@AllParametersAndReturnValuesAreNonnullByDefault
Package org.eclipse.ditto.services.utils.search
Encode control flow as data flow through akka streams for modular actor decomposition.
-
Class Summary Class Description SearchSource Source of search results for one query.SearchSourceBuilder Builder forSearchSource.SubscriptionActor Actor that translates subscription commands into stream operations and stream signals into subscription events.SubscriptionManager Actor that manages search subscriptions for 1 websocket connection or 1 ConnectionPersistenceActor.