public class SubscribeToStreamOptions
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected ConnectionMetadata |
metadata |
protected Timeouts |
timeouts |
| Modifier and Type | Method and Description |
|---|---|
T |
authenticated(UserCredentials credentials) |
T |
fromEnd() |
T |
fromRevision(long revision) |
T |
fromRevision(StreamRevision startRevision) |
T |
fromStart() |
static SubscribeToStreamOptions |
get() |
io.grpc.Metadata |
getMetadata() |
StreamRevision |
getStartingRevision() |
Timeouts |
getTimeouts() |
boolean |
hasUserCredentials() |
T |
notRequireLeader() |
T |
notResolveLinkTos() |
T |
requiresLeader() |
T |
requiresLeader(boolean value) |
T |
resolveLinkTos() |
T |
resolveLinkTos(boolean value) |
boolean |
shouldResolveLinkTos() |
T |
timeouts(Timeouts timeouts) |
protected Timeouts timeouts
protected final ConnectionMetadata metadata
public static SubscribeToStreamOptions get()
public StreamRevision getStartingRevision()
public T fromRevision(StreamRevision startRevision)
public T fromStart()
public T fromEnd()
public T fromRevision(long revision)
public boolean shouldResolveLinkTos()
public T resolveLinkTos(boolean value)
public T resolveLinkTos()
public T notResolveLinkTos()
public Timeouts getTimeouts()
public T timeouts(Timeouts timeouts)
public io.grpc.Metadata getMetadata()
public boolean hasUserCredentials()
public T authenticated(UserCredentials credentials)
public T requiresLeader()
public T notRequireLeader()
public T requiresLeader(boolean value)