Package io.servicetalk.concurrent.internal

Class ConcurrentTerminalSubscriber<T>

java.lang.Object

io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber<T>

Type Parameters:

T - The type of PublisherSource.Subscriber.

All Implemented Interfaces:

PublisherSource.Subscriber<T>

@Deprecated
public final class ConcurrentTerminalSubscriber<T>
extends Object
implements PublisherSource.Subscriber<T>

Deprecated.

This internal class will be removed in the future releases without a replacement. If you depend on it, consider copying into your codebase.

A PublisherSource.Subscriber that allows for concurrent delivery of terminal events.

Constructor Summary

Constructors

Constructor	Description
ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T> delegate)	Deprecated. Create a new instance.
ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T> delegate, boolean concurrentOnSubscribe)	Deprecated. Create a new instance.

Method Summary

Modifier and Type	Method	Description
boolean	deferredOnComplete()	Deprecated. Indicate that a onComplete() should be delivered after deliverDeferredTerminal() is later called.
boolean	deferredOnError(Throwable cause)	Deprecated. Indicate that a onError(Throwable) should be delivered after deliverDeferredTerminal() is later called.
void	deliverDeferredTerminal()	Deprecated. Try to deliver a terminal signal typically set by deferredOnComplete() or deferredOnError(Throwable).
void	onComplete()	Deprecated. Callback to signal completion of the PublisherSource for this Subscriber.
void	onError(Throwable t)	Deprecated. Callback to receive an error for this Subscriber.
void	onNext(T t)	Deprecated. Callback to receive a data element for this Subscriber.
void	onSubscribe(PublisherSource.Subscription subscription)	Deprecated. Callback to receive a PublisherSource.Subscription for this Subscriber.
boolean	processOnComplete()	Deprecated. Attempt to process onComplete().
boolean	processOnError(Throwable t)	Deprecated. Attempt to process onError(Throwable).

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentTerminalSubscriber

public ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T> delegate)

Deprecated.

Create a new instance.

Parameters:

delegate - The PublisherSource.Subscriber to delegate all signals to.

ConcurrentTerminalSubscriber

public ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T> delegate,
 boolean concurrentOnSubscribe)

Deprecated.

Create a new instance.

Parameters:

delegate - The PublisherSource.Subscriber to delegate all signals to.

concurrentOnSubscribe - false to not guard for concurrency on PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription). true means that PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) will be protected against concurrent invocation with terminal methods.

Method Details

onSubscribe

public void onSubscribe(PublisherSource.Subscription subscription)

Deprecated.

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<T>

Parameters:

subscription - PublisherSource.Subscription for this Subscriber.

onNext

public void onNext(@Nullable
 T t)

Deprecated.

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<T>

Parameters:

t - A data element.

onError

public void onError(Throwable t)

Deprecated.

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<T>

Parameters:

t - error for this Subscriber.

processOnError

public boolean processOnError(Throwable t)

Deprecated.

Attempt to process onError(Throwable).

Parameters:

t - The error to process.

Returns:

true if the terminal signal was propagated to the delegate PublisherSource.Subscriber.

onComplete

public void onComplete()

Deprecated.

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<T>

processOnComplete

public boolean processOnComplete()

Deprecated.

Attempt to process onComplete().

Returns:

true if the terminal signal was propagated to the delegate PublisherSource.Subscriber.

deferredOnComplete

public boolean deferredOnComplete()

Deprecated.

Indicate that a onComplete() should be delivered after deliverDeferredTerminal() is later called. deliverDeferredTerminal() MUST be subsequently called or the terminal signal may never be delivered. This signal may also be delivered if onNext(Object) is being concurrently invoked.

Returns:

true if the terminal signal was "queued" to be delivered and deliverDeferredTerminal() MUST subsequently be called. false if another thread is concurrently terminating this PublisherSource.Subscriber (this terminal signal may still be delivered).

See Also:

• deliverDeferredTerminal()

deferredOnError

public boolean deferredOnError(Throwable cause)

Deprecated.

Indicate that a onError(Throwable) should be delivered after deliverDeferredTerminal() is later called. deliverDeferredTerminal() MUST be subsequently called or the terminal signal may never be delivered. This signal may also be delivered if onNext(Object) is being concurrently invoked.

Parameters:

cause - The terminal error signal to be delivered later (either when deliverDeferredTerminal() is called or if onNext(Object) is being concurrently invoked).

Returns:

true if the terminal signal cause was "queued" to be delivered and deliverDeferredTerminal() MUST subsequently be called. false if another thread is concurrently terminating this PublisherSource.Subscriber (this terminal signal may still be delivered).

See Also:

• deliverDeferredTerminal()

deliverDeferredTerminal

public void deliverDeferredTerminal()

Deprecated.

Try to deliver a terminal signal typically set by deferredOnComplete() or deferredOnError(Throwable).