Package org.infinispan.reactive.publisher.impl

Class InnerPublisherSubscription.InnerPublisherSubscriptionBuilder<K,I,R>

java.lang.Object

org.infinispan.reactive.publisher.impl.InnerPublisherSubscription.InnerPublisherSubscriptionBuilder<K,I,R>

Enclosing class:

InnerPublisherSubscription<K,I,R,E>

public static class InnerPublisherSubscription.InnerPublisherSubscriptionBuilder<K,I,R>
extends Object

Constructor Summary

Constructors

Constructor	Description
InnerPublisherSubscriptionBuilder(ClusterPublisherManagerImpl<K,?>.org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.SubscriberHandler<I,R> parent, int batchSize, Supplier<Map.Entry<Address,IntSet>> supplier, Map<Address,Set<K>> excludedKeys, int topologyId)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InnerPublisherSubscriptionBuilder

public InnerPublisherSubscriptionBuilder(ClusterPublisherManagerImpl<K,?>.org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl.SubscriberHandler<I,R> parent,
 int batchSize,
 Supplier<Map.Entry<Address,IntSet>> supplier,
 Map<Address,Set<K>> excludedKeys,
 int topologyId)