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

Class StreamerPublisher<T>

java.lang.Object

org.apache.ignite.migrationtools.persistence.utils.pubsub.StreamerPublisher<T>

All Implemented Interfaces:

AutoCloseable, Flow.Publisher<T>, Flow.Subscription

public class StreamerPublisher<T>
extends Object
implements Flow.Publisher<T>, Flow.Subscription, AutoCloseable

Publisher for streamer. A lighter alternative to SubmissionPublisher. Single-threaded. Only supports one subscriber.

Constructor Summary

Constructors

Constructor	Description
StreamerPublisher()

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	close()
void	closeExceptionally(Throwable error)	Close with error.
boolean	offer(T item)	Offer a new item to the subscriber.
void	request(long n)
void	subscribe(Flow.Subscriber<? super T> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamerPublisher

public StreamerPublisher()

Method Details

subscribe

public void subscribe(Flow.Subscriber<? super T> subscriber)

Specified by:

subscribe in interface Flow.Publisher<T>

request

public void request(long n)

Specified by:

request in interface Flow.Subscription

cancel

public void cancel()

Specified by:

cancel in interface Flow.Subscription

offer

public boolean offer(T item)
              throws InterruptedException

Offer a new item to the subscriber.

Parameters:

item - Item to be offered.

Returns:

Whether the element was successfully published or not.

Throws:

InterruptedException - if the thread was interrupted.

closeExceptionally

public void closeExceptionally(Throwable error)

Close with error.

close

public void close()

Specified by:

close in interface AutoCloseable