Package com.eventstore.dbclient

Class AbstractRead

  • All Implemented Interfaces:
    org.reactivestreams.Publisher<ResolvedEvent>
    Direct Known Subclasses:
    ReadAll, ReadStream
    public abstract class AbstractRead
extends java.lang.Object
implements org.reactivestreams.Publisher<ResolvedEvent>

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected static com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder defaultReadOptions  
      protected io.grpc.Metadata metadata  

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected AbstractRead​(GrpcClient client, io.grpc.Metadata metadata)  

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      abstract com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder createOptions()  
      void subscribe​(org.reactivestreams.Subscriber<? super ResolvedEvent> subscriber)  

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • defaultReadOptions

        protected static final com.eventstore.dbclient.proto.streams.StreamsOuterClass.ReadReq.Options.Builder defaultReadOptions

      • metadata

        protected final io.grpc.Metadata metadata

    • Constructor Detail

      • AbstractRead

        protected AbstractRead​(GrpcClient client,
                       io.grpc.Metadata metadata)

    • Method Detail

      • createOptions

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

      • subscribe

        public void subscribe​(org.reactivestreams.Subscriber<? super ResolvedEvent> subscriber)
        Specified by:
        subscribe in interface org.reactivestreams.Publisher<ResolvedEvent>