Package io.servicetalk.concurrent.internal

Class TerminalNotification

java.lang.Object

io.servicetalk.concurrent.internal.TerminalNotification

public final class TerminalNotification
extends Object

Holder of Throwable.

Method Summary

Modifier and Type	Method	Description
Throwable	cause()	Returns the cause of error if this is an error notification.
static TerminalNotification	complete()	Returns a TerminalNotification for completion.
boolean	equals(Object o)
static TerminalNotification	error(Throwable cause)	Returns a TerminalNotification for cause.
int	hashCode()
void	terminate(CompletableSource.Subscriber subscriber)	Invoke CompletableSource.Subscriber.onComplete() or CompletableSource.Subscriber.onError(Throwable) on the passed subscriber.
void	terminate(CompletableSource.Subscriber subscriber, Throwable additionalCause)	Invoke CompletableSource.Subscriber.onError(Throwable) with the passed Throwable if this TerminalNotification is for completion.
void	terminate(PublisherSource.Subscriber<?> subscriber)	Invoke PublisherSource.Subscriber.onComplete() or PublisherSource.Subscriber.onError(Throwable) on the passed subscriber.
void	terminate(PublisherSource.Subscriber<?> subscriber, Throwable additionalCause)	Invoke PublisherSource.Subscriber.onError(Throwable) with the passed Throwable if this TerminalNotification is for completion.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Details

terminate

public void terminate(PublisherSource.Subscriber<?> subscriber)

Invoke PublisherSource.Subscriber.onComplete() or PublisherSource.Subscriber.onError(Throwable) on the passed subscriber.

Parameters:

subscriber - to terminate.

terminate

public void terminate(PublisherSource.Subscriber<?> subscriber,
 Throwable additionalCause)

Invoke PublisherSource.Subscriber.onError(Throwable) with the passed Throwable if this TerminalNotification is for completion.

If this TerminalNotification is for error, then the passed Throwable will be added as a suppressed cause to the existing Throwable. If this is an error notification, the associated cause will get updated with the additionalCause.

Parameters:

subscriber - to terminate.

additionalCause - Throwable which is used as the caus

terminate

public void terminate(CompletableSource.Subscriber subscriber,
 Throwable additionalCause)

Invoke CompletableSource.Subscriber.onError(Throwable) with the passed Throwable if this TerminalNotification is for completion.

If this TerminalNotification is for error, then the passed Throwable will be added as a suppressed cause to the existing Throwable. If this is an error notification, the associated cause will get updated with the additionalCause.

Parameters:

subscriber - to terminate.

additionalCause - Throwable which is used as the caus

terminate

public void terminate(CompletableSource.Subscriber subscriber)

Invoke CompletableSource.Subscriber.onComplete() or CompletableSource.Subscriber.onError(Throwable) on the passed subscriber.

Parameters:

subscriber - to terminate.

cause

@Nullable
public Throwable cause()

Returns the cause of error if this is an error notification.

Returns:

Throwable if this is an error notification, otherwise null.

error

public static TerminalNotification error(Throwable cause)

Returns a TerminalNotification for cause.

Parameters:

cause - for the notification.

Returns:

TerminalNotification for cause.

complete

public static TerminalNotification complete()

Returns a TerminalNotification for completion.

Returns:

TerminalNotification for completion.

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object