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

Packages that use StreamSignal

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

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

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

Modifier and Type	Method	Description
void	PersistentStreamImpl.onNext(StreamSignal streamSignal)

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

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

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

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

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

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

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

Method parameters in io.axoniq.axonserver.grpc.streams with type arguments of type StreamSignal

Modifier and Type	Method	Description
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.StreamObserver<StreamRequest>	PersistentStreamServiceGrpc.PersistentStreamServiceStub.openStream(io.grpc.stub.StreamObserver<StreamSignal> responseObserver)	Open a persistent event stream connection from a client.