org.infinispan.persistence.spi

Interface NonBlockingStore.SegmentedPublisher<Type>

Type Parameters:

Type - type of values in this Publisher.

All Superinterfaces:

org.reactivestreams.Publisher<Type>

All Known Implementing Classes:

SegmentPublisherWrapper, SingleSegmentPublisher

Enclosing interface:

NonBlockingStore<K,V>

public static interface NonBlockingStore.SegmentedPublisher<Type>
extends org.reactivestreams.Publisher<Type>

A Publisher that provides a stream of values and the segments to which those values map.

Method Summary

Modifier and Type	Method and Description
int	getSegment() Returns the segment for all keys in the publisher.

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Method Detail

getSegment

int getSegment()

Returns the segment for all keys in the publisher.

Returns:

segment the data the publisher provides maps to.