Package com.eventstore.dbclient

Class ReadStream

java.lang.Object

com.eventstore.dbclient.AbstractRead

com.eventstore.dbclient.ReadStream

All Implemented Interfaces:

org.reactivestreams.Publisher<ResolvedEvent>

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, long maxCount, ReadStreamOptions options)

Method Summary

Modifier and Type	Method	Description
com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder	createOptions()

Methods inherited from class com.eventstore.dbclient.AbstractRead

subscribe

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,
                  long maxCount,
                  ReadStreamOptions options)

Method Detail

createOptions

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

Specified by:

createOptions in class AbstractRead