Class CancelImmediatelySubscriber
java.lang.Object
io.servicetalk.concurrent.internal.CancelImmediatelySubscriber
- All Implemented Interfaces:
PublisherSource.Subscriber<Object>
public final class CancelImmediatelySubscriber
extends Object
implements PublisherSource.Subscriber<Object>
-
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptionvoid
Callback to signal completion of thePublisherSource
for thisSubscriber
.void
Callback to receive anerror
for thisSubscriber
.void
Callback to receive adata
element for thisSubscriber
.void
Callback to receive aPublisherSource.Subscription
for thisSubscriber
.
-
Field Details
-
INSTANCE
Singleton instance.
-
-
Method Details
-
onSubscribe
Description copied from interface:PublisherSource.Subscriber
Callback to receive aPublisherSource.Subscription
for thisSubscriber
.See Reactive Streams specifications for the rules about how and when this method will be invoked.
- Specified by:
onSubscribe
in interfacePublisherSource.Subscriber<Object>
- Parameters:
s
-PublisherSource.Subscription
for thisSubscriber
.
-
onNext
Description copied from interface:PublisherSource.Subscriber
Callback to receive adata
element for thisSubscriber
.See Reactive Streams specifications for the rules about how and when this method will be invoked.
- Specified by:
onNext
in interfacePublisherSource.Subscriber<Object>
- Parameters:
obj
- Adata
element.
-
onError
Description copied from interface:PublisherSource.Subscriber
Callback to receive anerror
for thisSubscriber
.See Reactive Streams specifications for the rules about how and when this method will be invoked.
- Specified by:
onError
in interfacePublisherSource.Subscriber<Object>
- Parameters:
t
-error
for thisSubscriber
.
-
onComplete
public void onComplete()Description copied from interface:PublisherSource.Subscriber
Callback to signal completion of thePublisherSource
for thisSubscriber
.See Reactive Streams specifications for the rules about how and when this method will be invoked.
- Specified by:
onComplete
in interfacePublisherSource.Subscriber<Object>
-