Package com.eventstore.dbclient

Class SubscribeToAll

java.lang.Object

com.eventstore.dbclient.AbstractRegularSubscription

com.eventstore.dbclient.SubscribeToAll

public class SubscribeToAll
extends AbstractRegularSubscription

Field Summary

Fields

Modifier and Type	Field	Description
protected SubscriptionFilter	filter

Fields inherited from class com.eventstore.dbclient.AbstractRegularSubscription

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

Constructor Summary

Constructors

Constructor	Description
SubscribeToAll(GrpcClient client, SubscriptionListener listener, UserCredentials credentials)

Method Summary

Modifier and Type	Method	Description
SubscribeToAll	authenticated(UserCredentials credentials)
protected com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder	createOptions()
SubscribeToAll	filter(SubscriptionFilter filter)
SubscribeToAll	fromEnd()
SubscribeToAll	fromPosition(Position position)
SubscribeToAll	fromStart()
SubscribeToAll	notRequireLeader()
SubscribeToAll	notResolveLinks()
SubscribeToAll	requiresLeader()
SubscribeToAll	requiresLeader(boolean value)
SubscribeToAll	resolveLinks()
SubscribeToAll	resolveLinks(boolean value)
SubscribeToAll	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

Field Detail

filter

protected SubscriptionFilter filter

Constructor Detail

SubscribeToAll

public SubscribeToAll(GrpcClient client,
                      SubscriptionListener listener,
                      UserCredentials credentials)

Method Detail

authenticated

public SubscribeToAll authenticated(UserCredentials credentials)

timeouts

public SubscribeToAll timeouts(Timeouts timeouts)

requiresLeader

public SubscribeToAll requiresLeader()

notRequireLeader

public SubscribeToAll notRequireLeader()

requiresLeader

public SubscribeToAll requiresLeader(boolean value)

resolveLinks

public SubscribeToAll resolveLinks(boolean value)

resolveLinks

public SubscribeToAll resolveLinks()

notResolveLinks

public SubscribeToAll notResolveLinks()

fromStart

public SubscribeToAll fromStart()

fromEnd

public SubscribeToAll fromEnd()

fromPosition

public SubscribeToAll fromPosition(Position position)

filter

public SubscribeToAll filter(SubscriptionFilter filter)

createOptions

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

Specified by:

createOptions in class AbstractRegularSubscription