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(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 Detail

InnerPublisherSubscriptionBuilder

public InnerPublisherSubscriptionBuilder(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)