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

Packages that use StreamEventsResponse

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

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

Methods in io.axoniq.axonserver.connector.event that return types with arguments of type StreamEventsResponse

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 StreamEventsResponse in io.axoniq.axonserver.connector.event.impl

Methods in io.axoniq.axonserver.connector.event.impl that return types with arguments of type StreamEventsResponse

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

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

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

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

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

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

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

Modifier and Type	Method	Description
StreamEventsResponse.Builder	StreamEventsResponse.Builder.mergeFrom(StreamEventsResponse other)
static StreamEventsResponse.Builder	StreamEventsResponse.newBuilder(StreamEventsResponse prototype)

Method parameters in io.axoniq.axonserver.grpc.event.dcb with type arguments of type StreamEventsResponse

Modifier and Type	Method	Description
default void	DcbEventStoreGrpc.AsyncService.stream(StreamEventsRequest request, io.grpc.stub.StreamObserver<StreamEventsResponse> responseObserver)	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.