io.servicetalk.client.servicediscoverer

Class ServiceDiscovererTestSubscriber<T>

java.lang.Object

io.servicetalk.client.servicediscoverer.ServiceDiscovererTestSubscriber<T>

All Implemented Interfaces:

PublisherSource.Subscriber<ServiceDiscovererEvent<T>>

public final class ServiceDiscovererTestSubscriber<T>
extends java.lang.Object
implements PublisherSource.Subscriber<ServiceDiscovererEvent<T>>

Constructor Summary

Constructors

Constructor and Description
ServiceDiscovererTestSubscriber(java.util.concurrent.CountDownLatch latch, java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> throwableRef, long initialRequestN)

Method Summary

Modifier and Type	Method and Description
int	activeCount()
int	inactiveCount()
void	onComplete() Callback to signal completion of the PublisherSource for this Subscriber.
void	onError(java.lang.Throwable t) Callback to receive an error for this Subscriber.
void	onNext(ServiceDiscovererEvent<T> event) Callback to receive a data element for this Subscriber.
void	onSubscribe(PublisherSource.Subscription s) Callback to receive a PublisherSource.Subscription for this Subscriber.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceDiscovererTestSubscriber

public ServiceDiscovererTestSubscriber(java.util.concurrent.CountDownLatch latch,
                                       java.util.concurrent.atomic.AtomicReference<java.lang.Throwable> throwableRef,
                                       long initialRequestN)

Method Detail

onSubscribe

public void onSubscribe(PublisherSource.Subscription s)

Description copied from interface: PublisherSource.Subscriber

Callback to receive a PublisherSource.Subscription for this Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Specified by:

onSubscribe in interface PublisherSource.Subscriber<ServiceDiscovererEvent<T>>

Parameters:

s - PublisherSource.Subscription for this Subscriber.

onNext

public void onNext(@Nonnull
                   ServiceDiscovererEvent<T> event)

Description copied from interface: PublisherSource.Subscriber

Callback to receive a data element for this Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Specified by:

onNext in interface PublisherSource.Subscriber<ServiceDiscovererEvent<T>>

Parameters:

event - A data element.

activeCount

public int activeCount()

inactiveCount

public int inactiveCount()

onError

public void onError(java.lang.Throwable t)

Description copied from interface: PublisherSource.Subscriber

Callback to receive an error for this Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Specified by:

onError in interface PublisherSource.Subscriber<ServiceDiscovererEvent<T>>

Parameters:

t - error for this Subscriber.

onComplete

public void onComplete()

Description copied from interface: PublisherSource.Subscriber

Callback to signal completion of the PublisherSource for this Subscriber.

See Reactive Streams specifications for the rules about how and when this method will be invoked.

Specified by:

onComplete in interface PublisherSource.Subscriber<ServiceDiscovererEvent<T>>