Uses of Class
io.axoniq.axonserver.grpc.streams.StreamRequest

Packages that use StreamRequest

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

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

Methods in io.axoniq.axonserver.connector.event.impl that return StreamRequest

Modifier and Type	Method	Description
protected StreamRequest	BufferedPersistentStreamSegment.buildFlowControlMessage(FlowControl flowControl)

Method parameters in io.axoniq.axonserver.connector.event.impl with type arguments of type StreamRequest

Modifier and Type	Method	Description
void	PersistentStreamImpl.beforeStart(io.grpc.stub.ClientCallStreamObserver<StreamRequest> clientCallStreamObserver)

Uses of StreamRequest in io.axoniq.axonserver.grpc.streams

Methods in io.axoniq.axonserver.grpc.streams that return StreamRequest

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

Methods in io.axoniq.axonserver.grpc.streams that return types with arguments of type StreamRequest

Modifier and Type	Method	Description
static io.grpc.MethodDescriptor<StreamRequest,StreamSignal>	PersistentStreamServiceGrpc.getOpenStreamMethod()
com.google.protobuf.Parser<StreamRequest>	StreamRequest.getParserForType()
default io.grpc.stub.StreamObserver<StreamRequest>	PersistentStreamServiceGrpc.AsyncService.openStream(io.grpc.stub.StreamObserver<StreamSignal> responseObserver)	Open a persistent event stream connection from a client.
io.grpc.stub.BlockingClientCall<StreamRequest,StreamSignal>	PersistentStreamServiceGrpc.PersistentStreamServiceBlockingV2Stub.openStream()	Open a persistent event stream connection from a client.
io.grpc.stub.StreamObserver<StreamRequest>	PersistentStreamServiceGrpc.PersistentStreamServiceStub.openStream(io.grpc.stub.StreamObserver<StreamSignal> responseObserver)	Open a persistent event stream connection from a client.
static com.google.protobuf.Parser<StreamRequest>	StreamRequest.parser()

Methods in io.axoniq.axonserver.grpc.streams with parameters of type StreamRequest

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