Uses of Interface
org.infinispan.stream.impl.ClusterStreamManager.RemoteIteratorPublisher
-
Packages that use ClusterStreamManager.RemoteIteratorPublisher Package Description org.infinispan.stream.impl org.infinispan.stream.impl.tx -
-
Uses of ClusterStreamManager.RemoteIteratorPublisher in org.infinispan.stream.impl
Methods in org.infinispan.stream.impl that return ClusterStreamManager.RemoteIteratorPublisher Modifier and Type Method Description <E> ClusterStreamManager.RemoteIteratorPublisher<E>
ClusterStreamManager. remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> segments, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intermediateOperations)
<E> ClusterStreamManager.RemoteIteratorPublisher<E>
ClusterStreamManagerImpl. remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> targets, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intermediateOperations)
<E> ClusterStreamManager.RemoteIteratorPublisher<E>
PartitionAwareClusterStreamManager. remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> targets, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intermediateOperations)
Methods in org.infinispan.stream.impl with parameters of type ClusterStreamManager.RemoteIteratorPublisher Modifier and Type Method Description org.reactivestreams.Publisher<S>
CompletionRehashPublisherDecorator. decorateRemote(ClusterStreamManager.RemoteIteratorPublisher<S> remotePublisher)
-
Uses of ClusterStreamManager.RemoteIteratorPublisher in org.infinispan.stream.impl.tx
Methods in org.infinispan.stream.impl.tx that return ClusterStreamManager.RemoteIteratorPublisher Modifier and Type Method Description <E> ClusterStreamManager.RemoteIteratorPublisher<E>
TxClusterStreamManager. remoteIterationPublisher(boolean parallelStream, Supplier<Map.Entry<Address,org.infinispan.commons.util.IntSet>> segments, Set<K> keysToInclude, IntFunction<Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intermediateOperations)
-