Package io.servicetalk.concurrent.internal

Class TerminalNotification

java.lang.Object

io.servicetalk.concurrent.internal.TerminalNotification

public final class TerminalNotification
extends java.lang.Object

Holder of Throwable.

Method Summary

Modifier and Type	Method	Description
java.lang.Throwable	cause()	Returns the cause of error if this is an error notification.
static TerminalNotification	complete()	Returns a TerminalNotification for completion.
static TerminalNotification	error(java.lang.Throwable cause)	Returns a TerminalNotification for cause.
void	terminate(CompletableSource.Subscriber subscriber)	Invoke CompletableSource.Subscriber.onComplete() or CompletableSource.Subscriber.onError(Throwable) on the passed subscriber.
void	terminate(CompletableSource.Subscriber subscriber, java.lang.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, java.lang.Throwable additionalCause)	Invoke PublisherSource.Subscriber.onError(Throwable) with the passed Throwable if this TerminalNotification is for completion.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

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,
                      java.lang.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,
                      java.lang.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 java.lang.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(java.lang.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 java.lang.String toString()

Overrides:

toString in class java.lang.Object