Class TerminalNotification
java.lang.Object
io.servicetalk.concurrent.internal.TerminalNotification
Holder of
Throwable
.-
Method Summary
Modifier and TypeMethodDescriptioncause()
Returns the cause of error if this is an error notification.static TerminalNotification
complete()
Returns aTerminalNotification
for completion.boolean
static TerminalNotification
Returns aTerminalNotification
forcause
.int
hashCode()
void
terminate
(CompletableSource.Subscriber subscriber) InvokeCompletableSource.Subscriber.onComplete()
orCompletableSource.Subscriber.onError(Throwable)
on the passedsubscriber
.void
terminate
(CompletableSource.Subscriber subscriber, Throwable additionalCause) InvokeCompletableSource.Subscriber.onError(Throwable)
with the passedThrowable
if thisTerminalNotification
is for completion.void
terminate
(PublisherSource.Subscriber<?> subscriber) InvokePublisherSource.Subscriber.onComplete()
orPublisherSource.Subscriber.onError(Throwable)
on the passedsubscriber
.void
terminate
(PublisherSource.Subscriber<?> subscriber, Throwable additionalCause) InvokePublisherSource.Subscriber.onError(Throwable)
with the passedThrowable
if thisTerminalNotification
is for completion.toString()
-
Method Details
-
terminate
InvokePublisherSource.Subscriber.onComplete()
orPublisherSource.Subscriber.onError(Throwable)
on the passedsubscriber
.- Parameters:
subscriber
- to terminate.
-
terminate
InvokePublisherSource.Subscriber.onError(Throwable)
with the passedThrowable
if thisTerminalNotification
is for completion.If this
TerminalNotification
is for error, then the passedThrowable
will be added as a suppressed cause to the existingThrowable
. If this is an error notification, the associated cause will get updated with theadditionalCause
.- Parameters:
subscriber
- to terminate.additionalCause
-Throwable
which is used as the caus
-
terminate
InvokeCompletableSource.Subscriber.onError(Throwable)
with the passedThrowable
if thisTerminalNotification
is for completion.If this
TerminalNotification
is for error, then the passedThrowable
will be added as a suppressed cause to the existingThrowable
. If this is an error notification, the associated cause will get updated with theadditionalCause
.- Parameters:
subscriber
- to terminate.additionalCause
-Throwable
which is used as the caus
-
terminate
InvokeCompletableSource.Subscriber.onComplete()
orCompletableSource.Subscriber.onError(Throwable)
on the passedsubscriber
.- Parameters:
subscriber
- to terminate.
-
cause
Returns the cause of error if this is an error notification.- Returns:
Throwable
if this is an error notification, otherwisenull
.
-
error
Returns aTerminalNotification
forcause
.- Parameters:
cause
- for the notification.- Returns:
TerminalNotification
forcause
.
-
complete
Returns aTerminalNotification
for completion.- Returns:
TerminalNotification
for completion.
-
toString
-
equals
-
hashCode
public int hashCode()
-