Package com.eventstore.dbclient

Class ReadStream

java.lang.Object

com.eventstore.dbclient.AbstractRead

com.eventstore.dbclient.ReadStream

public class ReadStream
extends AbstractRead

TODO - Implement a better way to handle very long stream to not end if OOM

Field Summary

Fields inherited from class com.eventstore.dbclient.AbstractRead

defaultReadOptions, metadata

Constructor Summary

Constructors

Constructor	Description
ReadStream(GrpcClient client, java.lang.String streamName, UserCredentials credentials)

Method Summary

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

Methods inherited from class com.eventstore.dbclient.AbstractRead

execute, readThrough

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadStream

public ReadStream(GrpcClient client,
                  java.lang.String streamName,
                  UserCredentials credentials)

Method Detail

authenticated

public ReadStream authenticated(UserCredentials credentials)

forward

public ReadStream forward()

backward

public ReadStream backward()

timeouts

public ReadStream timeouts(Timeouts timeouts)

requiresLeader

public ReadStream requiresLeader()

notRequireLeader

public ReadStream notRequireLeader()

requiresLeader

public ReadStream requiresLeader(boolean value)

resolveLinks

public ReadStream resolveLinks(boolean value)

resolveLinks

public ReadStream resolveLinks()

notResolveLinks

public ReadStream notResolveLinks()

startingPosition

public ReadStream startingPosition(StreamRevision startRevision)

fromStart

public ReadStream fromStart()

fromEnd

public ReadStream fromEnd()

fromRevision

public ReadStream fromRevision(long revision)

createOptions

public com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder createOptions(long count)

Specified by:

createOptions in class AbstractRead