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

Class DefaultStreamService

java.lang.Object

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

All Implemented Interfaces:

StreamService

public class DefaultStreamService
extends Object
implements StreamService

Constructor Summary

Constructors

Constructor	Description
DefaultStreamService(HttpHandler handler, InternalSettings settings, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
com.github.plokhotnyuk.jsoniter_scala.core.JsonValueCodec<StreamOutput>	codec()
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)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultStreamService

public DefaultStreamService(HttpHandler handler,
 InternalSettings settings,
 ClientExecutionContext clientExecutionContext)

Method Details

codec

public com.github.plokhotnyuk.jsoniter_scala.core.JsonValueCodec<StreamOutput> codec()

commit

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

Specified by:

commit in interface StreamService

consume

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

Specified by:

consume in interface StreamService

subscribe

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

Specified by:

subscribe in interface StreamService

unsubscribe

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

Specified by:

unsubscribe in interface StreamService