Uses of Class
io.axoniq.axonserver.grpc.event.dcb.SourceEventsResponse
-
Packages that use SourceEventsResponse Package Description io.axoniq.axonserver.connector.event io.axoniq.axonserver.connector.event.impl io.axoniq.axonserver.grpc.event.dcb -
-
Uses of SourceEventsResponse in io.axoniq.axonserver.connector.event
Methods in io.axoniq.axonserver.connector.event that return types with arguments of type SourceEventsResponse Modifier and Type Method Description ResultStream<SourceEventsResponse>DcbEventChannel. source(SourceEventsRequest request)Provides a finite stream of events used to eventsource a model. -
Uses of SourceEventsResponse in io.axoniq.axonserver.connector.event.impl
Methods in io.axoniq.axonserver.connector.event.impl that return types with arguments of type SourceEventsResponse Modifier and Type Method Description ResultStream<SourceEventsResponse>DcbEventChannelImpl. source(SourceEventsRequest request) -
Uses of SourceEventsResponse in io.axoniq.axonserver.grpc.event.dcb
Methods in io.axoniq.axonserver.grpc.event.dcb that return SourceEventsResponse Modifier and Type Method Description SourceEventsResponseSourceEventsResponse.Builder. build()SourceEventsResponseSourceEventsResponse.Builder. buildPartial()static SourceEventsResponseSourceEventsResponse. getDefaultInstance()SourceEventsResponseSourceEventsResponse.Builder. getDefaultInstanceForType()SourceEventsResponseSourceEventsResponse. getDefaultInstanceForType()static SourceEventsResponseSourceEventsResponse. parseDelimitedFrom(InputStream input)static SourceEventsResponseSourceEventsResponse. parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static SourceEventsResponseSourceEventsResponse. parseFrom(byte[] data)static SourceEventsResponseSourceEventsResponse. parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static SourceEventsResponseSourceEventsResponse. parseFrom(com.google.protobuf.ByteString data)static SourceEventsResponseSourceEventsResponse. parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static SourceEventsResponseSourceEventsResponse. parseFrom(com.google.protobuf.CodedInputStream input)static SourceEventsResponseSourceEventsResponse. parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static SourceEventsResponseSourceEventsResponse. parseFrom(InputStream input)static SourceEventsResponseSourceEventsResponse. parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static SourceEventsResponseSourceEventsResponse. parseFrom(ByteBuffer data)static SourceEventsResponseSourceEventsResponse. parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)Methods in io.axoniq.axonserver.grpc.event.dcb that return types with arguments of type SourceEventsResponse Modifier and Type Method Description com.google.protobuf.Parser<SourceEventsResponse>SourceEventsResponse. getParserForType()static io.grpc.MethodDescriptor<SourceEventsRequest,SourceEventsResponse>DcbEventStoreGrpc. getSourceMethod()static com.google.protobuf.Parser<SourceEventsResponse>SourceEventsResponse. parser()Iterator<SourceEventsResponse>DcbEventStoreGrpc.DcbEventStoreBlockingStub. source(SourceEventsRequest request)Provides a finite stream of events based on the passed SourceEventsRequest.io.grpc.stub.BlockingClientCall<?,SourceEventsResponse>DcbEventStoreGrpc.DcbEventStoreBlockingV2Stub. source(SourceEventsRequest request)Provides a finite stream of events based on the passed SourceEventsRequest.Methods in io.axoniq.axonserver.grpc.event.dcb with parameters of type SourceEventsResponse Modifier and Type Method Description SourceEventsResponse.BuilderSourceEventsResponse.Builder. mergeFrom(SourceEventsResponse other)static SourceEventsResponse.BuilderSourceEventsResponse. newBuilder(SourceEventsResponse prototype)Method parameters in io.axoniq.axonserver.grpc.event.dcb with type arguments of type SourceEventsResponse Modifier and Type Method Description default voidDcbEventStoreGrpc.AsyncService. source(SourceEventsRequest request, io.grpc.stub.StreamObserver<SourceEventsResponse> responseObserver)Provides a finite stream of events based on the passed SourceEventsRequest.voidDcbEventStoreGrpc.DcbEventStoreStub. source(SourceEventsRequest request, io.grpc.stub.StreamObserver<SourceEventsResponse> responseObserver)Provides a finite stream of events based on the passed SourceEventsRequest.
-