Class InnerPublisherSubscription.InnerPublisherSubscriptionBuilder<K,​I,​R>

    • 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)