com.eventstore.dbclient

Class AbstractRegularSubscription

java.lang.Object

com.eventstore.dbclient.AbstractRegularSubscription

Direct Known Subclasses:

SubscribeToAll, SubscribeToStream

public abstract class AbstractRegularSubscription
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Checkpointer	checkpointer
protected static com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder	defaultReadOptions
protected static com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder	defaultSubscribeOptions
protected SubscriptionListener	listener
protected io.grpc.Metadata	metadata

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractRegularSubscription(GrpcClient client, io.grpc.Metadata metadata)

Method Summary

Modifier and Type	Method and Description
protected abstract com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder	createOptions()
java.util.concurrent.CompletableFuture<Subscription>	execute()

Methods inherited from class java.lang.Object

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

Field Detail

defaultReadOptions

protected static final com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder defaultReadOptions

defaultSubscribeOptions

protected static final com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder defaultSubscribeOptions

metadata

protected io.grpc.Metadata metadata

listener

protected SubscriptionListener listener

checkpointer

protected Checkpointer checkpointer

Constructor Detail

AbstractRegularSubscription

protected AbstractRegularSubscription(GrpcClient client,
                                      io.grpc.Metadata metadata)

Method Detail

createOptions

protected abstract com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder createOptions()

execute

public java.util.concurrent.CompletableFuture<Subscription> execute()