Uses of Class
io.axoniq.axonserver.grpc.event.dcb.StreamEventsRequest

Packages that use StreamEventsRequest

Package	Description
io.axoniq.axonserver.connector.event
io.axoniq.axonserver.connector.event.impl
io.axoniq.axonserver.grpc.event.dcb

Uses of StreamEventsRequest in io.axoniq.axonserver.connector.event

Methods in io.axoniq.axonserver.connector.event with parameters of type StreamEventsRequest

Modifier and Type	Method	Description
default ResultStream<StreamEventsResponse>	DcbEventChannel.stream(StreamEventsRequest request)	Opens an infinite stream of events, for sequentially consuming events from Axon Server, using the given request and keeping a local buffer of 64 events.
default ResultStream<StreamEventsResponse>	DcbEventChannel.stream(StreamEventsRequest request, int bufferSize)	Opens an infinite stream of events, for sequentially consuming events from Axon Server, using the given request and keeping a local buffer of bufferSize.
ResultStream<StreamEventsResponse>	DcbEventChannel.stream(StreamEventsRequest request, int bufferSize, int refillBatch)	Opens an infinite stream of events, for sequentially consuming events from Axon Server, using the given request and keeping a local buffer of bufferSize, which is refilled after consuming refillBatch events.

Uses of StreamEventsRequest in io.axoniq.axonserver.connector.event.impl

Methods in io.axoniq.axonserver.connector.event.impl with parameters of type StreamEventsRequest

Modifier and Type	Method	Description
ResultStream<StreamEventsResponse>	DcbEventChannelImpl.stream(StreamEventsRequest request, int bufferSize, int refillBatch)

Uses of StreamEventsRequest in io.axoniq.axonserver.grpc.event.dcb

Methods in io.axoniq.axonserver.grpc.event.dcb that return StreamEventsRequest

Modifier and Type	Method	Description
StreamEventsRequest	StreamEventsRequest.Builder.build()
StreamEventsRequest	StreamEventsRequest.Builder.buildPartial()
static StreamEventsRequest	StreamEventsRequest.getDefaultInstance()
StreamEventsRequest	StreamEventsRequest.Builder.getDefaultInstanceForType()
StreamEventsRequest	StreamEventsRequest.getDefaultInstanceForType()
static StreamEventsRequest	StreamEventsRequest.parseDelimitedFrom(InputStream input)
static StreamEventsRequest	StreamEventsRequest.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamEventsRequest	StreamEventsRequest.parseFrom(byte[] data)
static StreamEventsRequest	StreamEventsRequest.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamEventsRequest	StreamEventsRequest.parseFrom(com.google.protobuf.ByteString data)
static StreamEventsRequest	StreamEventsRequest.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamEventsRequest	StreamEventsRequest.parseFrom(com.google.protobuf.CodedInputStream input)
static StreamEventsRequest	StreamEventsRequest.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamEventsRequest	StreamEventsRequest.parseFrom(InputStream input)
static StreamEventsRequest	StreamEventsRequest.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamEventsRequest	StreamEventsRequest.parseFrom(ByteBuffer data)
static StreamEventsRequest	StreamEventsRequest.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in io.axoniq.axonserver.grpc.event.dcb that return types with arguments of type StreamEventsRequest

Modifier and Type	Method	Description
com.google.protobuf.Parser<StreamEventsRequest>	StreamEventsRequest.getParserForType()
static io.grpc.MethodDescriptor<StreamEventsRequest,StreamEventsResponse>	DcbEventStoreGrpc.getStreamMethod()
static com.google.protobuf.Parser<StreamEventsRequest>	StreamEventsRequest.parser()

Methods in io.axoniq.axonserver.grpc.event.dcb with parameters of type StreamEventsRequest

Modifier and Type	Method	Description
StreamEventsRequest.Builder	StreamEventsRequest.Builder.mergeFrom(StreamEventsRequest other)
static StreamEventsRequest.Builder	StreamEventsRequest.newBuilder(StreamEventsRequest prototype)
default void	DcbEventStoreGrpc.AsyncService.stream(StreamEventsRequest request, io.grpc.stub.StreamObserver<StreamEventsResponse> responseObserver)	Provides an infinite stream of events based on the passed StreamEventsRequest.
Iterator<StreamEventsResponse>	DcbEventStoreGrpc.DcbEventStoreBlockingStub.stream(StreamEventsRequest request)	Provides an infinite stream of events based on the passed StreamEventsRequest.
io.grpc.stub.BlockingClientCall<?,StreamEventsResponse>	DcbEventStoreGrpc.DcbEventStoreBlockingV2Stub.stream(StreamEventsRequest request)	Provides an infinite stream of events based on the passed StreamEventsRequest.
void	DcbEventStoreGrpc.DcbEventStoreStub.stream(StreamEventsRequest request, io.grpc.stub.StreamObserver<StreamEventsResponse> responseObserver)	Provides an infinite stream of events based on the passed StreamEventsRequest.