Uses of Interface
org.infinispan.persistence.spi.NonBlockingStore.SegmentedPublisher

Packages that use NonBlockingStore.SegmentedPublisher

Package	Description
org.infinispan.persistence.async
org.infinispan.persistence.jdbc.common.impl
org.infinispan.persistence.remote	Hot Rod-based AdvancedLoadWriteStore.
org.infinispan.persistence.rocksdb	RocksDB-based AdvancedLoadWriteStore.
org.infinispan.persistence.spi	The Persistence SPI.
org.infinispan.persistence.support

Uses of NonBlockingStore.SegmentedPublisher in org.infinispan.persistence.async

Method parameters in org.infinispan.persistence.async with type arguments of type NonBlockingStore.SegmentedPublisher

Modifier and Type	Method	Description
CompletionStage<Void>	AsyncNonBlockingStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)

Uses of NonBlockingStore.SegmentedPublisher in org.infinispan.persistence.jdbc.common.impl

Method parameters in org.infinispan.persistence.jdbc.common.impl with type arguments of type NonBlockingStore.SegmentedPublisher

Modifier and Type	Method	Description
CompletionStage<Void>	BaseJdbcStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
CompletionStage<Void>	BaseJdbcStore.prepareWithModifications(jakarta.transaction.Transaction tx, int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)

Uses of NonBlockingStore.SegmentedPublisher in org.infinispan.persistence.remote

Method parameters in org.infinispan.persistence.remote with type arguments of type NonBlockingStore.SegmentedPublisher

Modifier and Type	Method	Description
CompletionStage<Void>	RemoteStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)

Uses of NonBlockingStore.SegmentedPublisher in org.infinispan.persistence.rocksdb

Method parameters in org.infinispan.persistence.rocksdb with type arguments of type NonBlockingStore.SegmentedPublisher

Modifier and Type	Method	Description
CompletionStage<Void>	RocksDBStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)

Uses of NonBlockingStore.SegmentedPublisher in org.infinispan.persistence.spi

Method parameters in org.infinispan.persistence.spi with type arguments of type NonBlockingStore.SegmentedPublisher

Modifier and Type	Method	Description
default CompletionStage<Void>	NonBlockingStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)	Writes and removes the entries provided by the Publishers into the store.
default CompletionStage<Void>	NonBlockingStore.prepareWithModifications(jakarta.transaction.Transaction transaction, int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)	Write remove and put modifications to the store in the prepare phase, which should not yet persisted until the same transaction is committed via NonBlockingStore.commit(Transaction) or they are discarded if the transaction is rolled back via NonBlockingStore.rollback(Transaction).

Uses of NonBlockingStore.SegmentedPublisher in org.infinispan.persistence.support

Classes in org.infinispan.persistence.support that implement NonBlockingStore.SegmentedPublisher

Modifier and Type	Class	Description
class	SegmentPublisherWrapper<Type>
class	SingleSegmentPublisher<E>

Methods in org.infinispan.persistence.support that return NonBlockingStore.SegmentedPublisher

Modifier and Type	Method	Description
static <E> NonBlockingStore.SegmentedPublisher<E>	SingleSegmentPublisher.singleSegment(int segment, org.reactivestreams.Publisher<? extends E> publisher)
static <E> NonBlockingStore.SegmentedPublisher<E>	SingleSegmentPublisher.singleSegment(org.reactivestreams.Publisher<? extends E> publisher)

Method parameters in org.infinispan.persistence.support with type arguments of type NonBlockingStore.SegmentedPublisher

Modifier and Type	Method	Description
CompletionStage<Void>	DelegatingNonBlockingStore.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
CompletionStage<Void>	NonBlockingStoreAdapter.batch(int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
CompletionStage<Void>	DelegatingNonBlockingStore.prepareWithModifications(jakarta.transaction.Transaction transaction, int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
CompletionStage<Void>	NonBlockingStoreAdapter.prepareWithModifications(jakarta.transaction.Transaction transaction, int publisherCount, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<Object>> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)