Uses of Class
io.axoniq.axonserver.grpc.event.EventWithToken

Packages that use EventWithToken

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

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

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

Modifier and Type	Method	Description
protected EventWithToken	BufferedEventStream.terminalMessage()

Uses of EventWithToken in io.axoniq.axonserver.connector.event.transformation.event

Method parameters in io.axoniq.axonserver.connector.event.transformation.event with type arguments of type EventWithToken

Modifier and Type	Method	Description
TransformableEventStream	TransformableEventStream.filter(Predicate<EventWithToken> predicate)	Filters events based on the provided predicate.
static TransformableEventStream	EventSources.fromIterable(Iterable<EventWithToken> events)	Creates a TransformableEventStream based on the Iterable of events.

Uses of EventWithToken in io.axoniq.axonserver.connector.event.transformation.event.impl

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

Modifier and Type	Method	Description
TransformableEventStream	TransformableEventIterable.filter(Predicate<EventWithToken> predicate)

Constructor parameters in io.axoniq.axonserver.connector.event.transformation.event.impl with type arguments of type EventWithToken

Constructor	Description
TransformableEventIterable(Iterable<EventWithToken> events)	Constructs an instance based on the specified Iterable

Uses of EventWithToken in io.axoniq.axonserver.connector.event.transformation.event.stream

Methods in io.axoniq.axonserver.connector.event.transformation.event.stream that return types with arguments of type EventWithToken

Modifier and Type	Method	Description
Iterator<EventWithToken>	TokenRangeEvents.iterator()

Uses of EventWithToken in io.axoniq.axonserver.grpc.event

Methods in io.axoniq.axonserver.grpc.event that return EventWithToken

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

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

Modifier and Type	Method	Description
static io.grpc.MethodDescriptor<GetEventsRequest,EventWithToken>	EventStoreGrpc.getListEventsMethod()
com.google.protobuf.Parser<EventWithToken>	EventWithToken.getParserForType()
io.grpc.stub.BlockingClientCall<GetEventsRequest,EventWithToken>	EventStoreGrpc.EventStoreBlockingV2Stub.listEvents()	Retrieves the Events from a given tracking token.
static com.google.protobuf.Parser<EventWithToken>	EventWithToken.parser()

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

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

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

Modifier and Type	Method	Description
default io.grpc.stub.StreamObserver<GetEventsRequest>	EventStoreGrpc.AsyncService.listEvents(io.grpc.stub.StreamObserver<EventWithToken> responseObserver)	Retrieves the Events from a given tracking token.
io.grpc.stub.StreamObserver<GetEventsRequest>	EventStoreGrpc.EventStoreStub.listEvents(io.grpc.stub.StreamObserver<EventWithToken> responseObserver)	Retrieves the Events from a given tracking token.

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

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

Modifier and Type	Method	Description
EventWithToken	PersistentStreamEvent.Builder.getEvent()	an event to process in the client
EventWithToken	PersistentStreamEvent.getEvent()	an event to process in the client
EventWithToken	PersistentStreamEventOrBuilder.getEvent()	an event to process in the client

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

Modifier and Type	Method	Description
PersistentStreamEvent.Builder	PersistentStreamEvent.Builder.mergeEvent(EventWithToken value)	an event to process in the client
PersistentStreamEvent.Builder	PersistentStreamEvent.Builder.setEvent(EventWithToken value)	an event to process in the client