Package com.here.platform.data.client.javadsl

Class Subscription

java.lang.Object

com.here.platform.data.client.javadsl.Subscription

public final class Subscription
extends Object

An subscription to a stream layer with access to the Source of partitions and control operation.

Constructor Summary

Constructors

Constructor	Description
Subscription(org.apache.pekko.stream.javadsl.Source<Partition,org.apache.pekko.NotUsed> partitions, SubscriptionControl subscriptionControl)

Method Summary

Modifier and Type	Method	Description
org.apache.pekko.stream.javadsl.Source<Partition,org.apache.pekko.NotUsed>	getPartitions()
SubscriptionControl	getSubscriptionControl()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Subscription

public Subscription(org.apache.pekko.stream.javadsl.Source<Partition,org.apache.pekko.NotUsed> partitions,
 SubscriptionControl subscriptionControl)

Method Details

getPartitions

public org.apache.pekko.stream.javadsl.Source<Partition,org.apache.pekko.NotUsed> getPartitions()

getSubscriptionControl

public SubscriptionControl getSubscriptionControl()