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

Packages that use NonBlockingStore.SegmentedPublisher

Package	Description
org.infinispan.persistence.remote	Hot Rod-based AdvancedLoadWriteStore.
org.infinispan.persistence.rocksdb	RocksDB-based AdvancedLoadWriteStore.
org.infinispan.persistence.spi	The Persistence SPI.

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(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).