Package com.here.platform.data.client.service.stream

Interface StreamService

All Known Implementing Classes:

DefaultStreamService

public interface StreamService

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<org.apache.pekko.Done>	commit(StreamSubscription subscription, CommitOffsets offsets)
scala.concurrent.Future<scala.collection.immutable.Seq<StreamMessage>>	consume(StreamSubscription subscription)
scala.concurrent.Future<StreamSubscription>	subscribe(HRN hrn, String layer, String groupName, Offset offset, String consumerId)
scala.concurrent.Future<org.apache.pekko.Done>	unsubscribe(StreamSubscription subscription)

Method Details

commit

scala.concurrent.Future<org.apache.pekko.Done> commit(StreamSubscription subscription,
 CommitOffsets offsets)

consume

scala.concurrent.Future<scala.collection.immutable.Seq<StreamMessage>> consume(StreamSubscription subscription)

subscribe

scala.concurrent.Future<StreamSubscription> subscribe(HRN hrn,
 String layer,
 String groupName,
 Offset offset,
 String consumerId)

unsubscribe

scala.concurrent.Future<org.apache.pekko.Done> unsubscribe(StreamSubscription subscription)