Uses of Class
com.exoreaction.xorcery.reactivestreams.api.WithMetadata

Packages that use WithMetadata

Package	Description
com.exoreaction.xorcery.benchmarks.reactivestreams
com.exoreaction.xorcery.domainevents.neo4jprojections
com.exoreaction.xorcery.domainevents.publisher
com.exoreaction.xorcery.eventstore.streams
com.exoreaction.xorcery.log4jpublisher
com.exoreaction.xorcery.log4jpublisher.log4j
com.exoreaction.xorcery.neo4jprojections.api
com.exoreaction.xorcery.neo4jprojections.spi
com.exoreaction.xorcery.reactivestreams.api
com.exoreaction.xorcery.reactivestreams.persistentsubscriber
com.exoreaction.xorcery.reactivestreams.persistentsubscriber.filter
com.exoreaction.xorcery.reactivestreams.persistentsubscriber.providers
com.exoreaction.xorcery.reactivestreams.persistentsubscriber.spi
com.exoreaction.xorcery.requestlogpublisher

Uses of WithMetadata in com.exoreaction.xorcery.benchmarks.reactivestreams

Methods in com.exoreaction.xorcery.benchmarks.reactivestreams with parameters of type WithMetadata

Modifier and Type	Method	Description
void	PublishSubscriberBenchmarks.ClientPublisher.publish(WithMetadata<String> item)

Method parameters in com.exoreaction.xorcery.benchmarks.reactivestreams with type arguments of type WithMetadata

Modifier and Type	Method	Description
void	PublishSubscriberWithResultBenchmarks.ClientPublisher.publish(WithResult<WithMetadata<String>,Integer> item)
void	PublishSubscriberBenchmarks.ClientPublisher.subscribe(Subscriber<? super WithMetadata<String>> subscriber)
void	PublishSubscriberWithResultBenchmarks.ClientPublisher.subscribe(Subscriber<? super WithResult<WithMetadata<String>,Integer>> subscriber)

Uses of WithMetadata in com.exoreaction.xorcery.domainevents.neo4jprojections

Methods in com.exoreaction.xorcery.domainevents.neo4jprojections with parameters of type WithMetadata

Modifier and Type	Method	Description
void	JsonDomainEventNeo4jEventProjection.write(WithMetadata<ArrayNode> events, Transaction transaction)

Uses of WithMetadata in com.exoreaction.xorcery.domainevents.publisher

Method parameters in com.exoreaction.xorcery.domainevents.publisher with type arguments of type WithMetadata

Modifier and Type	Method	Description
void	DomainEventsService.subscribe(Subscriber<? super WithResult<WithMetadata<DomainEvents>,Metadata>> subscriber)

Uses of WithMetadata in com.exoreaction.xorcery.eventstore.streams

Methods in com.exoreaction.xorcery.eventstore.streams with parameters of type WithMetadata

Modifier and Type	Method	Description
void	EventStoreSubscriberEventHandler.onEvent(WithMetadata<ByteBuffer> event, long sequence, boolean endOfBatch)
void	EventStoreSubscriber.onNext(WithMetadata<ByteBuffer> item)

Method parameters in com.exoreaction.xorcery.eventstore.streams with type arguments of type WithMetadata

Modifier and Type	Method	Description
void	EventStorePublisher.subscribe(Subscriber<? super WithMetadata<ByteBuffer>> subscriber)

Uses of WithMetadata in com.exoreaction.xorcery.log4jpublisher

Methods in com.exoreaction.xorcery.log4jpublisher with parameters of type WithMetadata

Modifier and Type	Method	Description
void	LoggingMetadataEventHandler.onEvent(WithMetadata<LogEvent> event, long seq, boolean endOfBatch)

Method parameters in com.exoreaction.xorcery.log4jpublisher with type arguments of type WithMetadata

Modifier and Type	Method	Description
void	Log4jPublisherService.LogPublisher.subscribe(Subscriber<? super WithMetadata<LogEvent>> subscriber)

Uses of WithMetadata in com.exoreaction.xorcery.log4jpublisher.log4j

Methods in com.exoreaction.xorcery.log4jpublisher.log4j that return types with arguments of type WithMetadata

Modifier and Type	Method	Description
UnicastEventHandler<WithMetadata<LogEvent>>	Log4jPublisherAppender.getUnicastEventHandler()

Uses of WithMetadata in com.exoreaction.xorcery.neo4jprojections.api

Methods in com.exoreaction.xorcery.neo4jprojections.api that return types with arguments of type WithMetadata

Modifier and Type	Method	Description
CompletableFuture<WithMetadata<ProjectionCommit>>	WaitForProjectionCommit.waitForTimestamp(long timestamp)
CompletableFuture<WithMetadata<ProjectionCommit>>	WaitForProjectionCommit.waitForVersion(long version)

Methods in com.exoreaction.xorcery.neo4jprojections.api with parameters of type WithMetadata

Modifier and Type	Method	Description
void	WaitForProjectionCommit.onNext(WithMetadata<ProjectionCommit> item)

Uses of WithMetadata in com.exoreaction.xorcery.neo4jprojections.spi

Methods in com.exoreaction.xorcery.neo4jprojections.spi with parameters of type WithMetadata

Modifier and Type	Method	Description
void	Neo4jEventProjection.write(WithMetadata<ArrayNode> events, Transaction transaction)

Uses of WithMetadata in com.exoreaction.xorcery.reactivestreams.api

Methods in com.exoreaction.xorcery.reactivestreams.api with parameters of type WithMetadata

Modifier and Type	Method	Description
void	WithMetadata.set(WithMetadata<T> other)

Uses of WithMetadata in com.exoreaction.xorcery.reactivestreams.persistentsubscriber

Methods in com.exoreaction.xorcery.reactivestreams.persistentsubscriber with parameters of type WithMetadata

Modifier and Type	Method	Description
void	PersistentSubscriberSubscriber.onNext(WithMetadata<ArrayNode> arrayNodeWithMetadata)

Uses of WithMetadata in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.filter

Methods in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.filter with parameters of type WithMetadata

Modifier and Type	Method	Description
boolean	SkipUntilTimestampFilter.test(WithMetadata<ArrayNode> arrayNodeWithMetadata)

Uses of WithMetadata in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.providers

Fields in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.providers with type parameters of type WithMetadata

Modifier and Type	Field	Description
protected Predicate<WithMetadata<ArrayNode>>	BasePersistentSubscriber.filter

Methods in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.providers that return types with arguments of type WithMetadata

Modifier and Type	Method	Description
Predicate<WithMetadata<ArrayNode>>	BasePersistentSubscriber.getFilter()

Methods in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.providers with parameters of type WithMetadata

Modifier and Type	Method	Description
void	FilePersistentSubscriberErrorLog.handle(WithMetadata<ArrayNode> arrayNodeWithMetadata, Throwable exception)

Uses of WithMetadata in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.spi

Methods in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.spi that return types with arguments of type WithMetadata

Modifier and Type	Method	Description
default Predicate<WithMetadata<ArrayNode>>	PersistentSubscriber.getFilter()

Methods in com.exoreaction.xorcery.reactivestreams.persistentsubscriber.spi with parameters of type WithMetadata

Modifier and Type	Method	Description
void	PersistentSubscriber.handle(WithMetadata<ArrayNode> eventsWithMetadata, CompletableFuture<Void> result)
void	PersistentSubscriberErrorLog.handle(WithMetadata<ArrayNode> arrayNodeWithMetadata, Throwable exception)

Uses of WithMetadata in com.exoreaction.xorcery.requestlogpublisher

Methods in com.exoreaction.xorcery.requestlogpublisher with parameters of type WithMetadata

Modifier and Type	Method	Description
void	RequestLogPublisherService.RequestLogPublisher.send(WithMetadata<ObjectNode> event)

Method parameters in com.exoreaction.xorcery.requestlogpublisher with type arguments of type WithMetadata

Modifier and Type	Method	Description
void	RequestLogPublisherService.RequestLogPublisher.subscribe(Subscriber<? super WithMetadata<ObjectNode>> subscriber)