Package com.eventstore.dbclient

Class SubscribeToStream

java.lang.Object

com.eventstore.dbclient.AbstractRegularSubscription

com.eventstore.dbclient.SubscribeToStream

public class SubscribeToStream
extends AbstractRegularSubscription

Field Summary

Fields inherited from class com.eventstore.dbclient.AbstractRegularSubscription

checkpointer, defaultReadOptions, defaultSubscribeOptions, listener, metadata, resolveLinks, timeouts

Constructor Summary

Constructors

Constructor	Description
SubscribeToStream(GrpcClient client, java.lang.String streamName, SubscriptionListener listener, UserCredentials credentials)

Method Summary

Modifier and Type	Method	Description
SubscribeToStream	authenticated(UserCredentials credentials)
protected com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder	createOptions()
SubscribeToStream	fromEnd()
SubscribeToStream	fromRevision(long revision)
SubscribeToStream	fromStart()
SubscribeToStream	notRequireLeader()
SubscribeToStream	notResolveLinks()
SubscribeToStream	requiresLeader()
SubscribeToStream	requiresLeader(boolean value)
SubscribeToStream	resolveLinks()
SubscribeToStream	resolveLinks(boolean value)
SubscribeToStream	startingPosition(StreamRevision startRevision)
SubscribeToStream	timeouts(Timeouts timeouts)

Methods inherited from class com.eventstore.dbclient.AbstractRegularSubscription

execute

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscribeToStream

public SubscribeToStream(GrpcClient client,
                         java.lang.String streamName,
                         SubscriptionListener listener,
                         UserCredentials credentials)

Method Detail

authenticated

public SubscribeToStream authenticated(UserCredentials credentials)

timeouts

public SubscribeToStream timeouts(Timeouts timeouts)

requiresLeader

public SubscribeToStream requiresLeader()

notRequireLeader

public SubscribeToStream notRequireLeader()

requiresLeader

public SubscribeToStream requiresLeader(boolean value)

resolveLinks

public SubscribeToStream resolveLinks(boolean value)

resolveLinks

public SubscribeToStream resolveLinks()

notResolveLinks

public SubscribeToStream notResolveLinks()

startingPosition

public SubscribeToStream startingPosition(StreamRevision startRevision)

fromStart

public SubscribeToStream fromStart()

fromEnd

public SubscribeToStream fromEnd()

fromRevision

public SubscribeToStream fromRevision(long revision)

createOptions

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

Specified by:

createOptions in class AbstractRegularSubscription