Package org.apache.ignite.migrationtools.persistence.utils.pubsub

package org.apache.ignite.migrationtools.persistence.utils.pubsub

Classes

Class	Description
BasicProcessor<S,T>	Base class for building Flow.Processor which provides a transparent layer between a single publisher and a single subscriber.
RateLimiterProcessor<S>	Limits the upstream rate of the downstream processor/publisher.
StreamerPublisher<T>	Publisher for streamer.