Class CancelImmediatelySubscriber
- java.lang.Object
-
- io.servicetalk.concurrent.internal.CancelImmediatelySubscriber
-
- All Implemented Interfaces:
PublisherSource.Subscriber<java.lang.Object>
public final class CancelImmediatelySubscriber extends java.lang.Object implements PublisherSource.Subscriber<java.lang.Object>
-
-
Field Summary
Fields Modifier and Type Field Description static CancelImmediatelySubscriber
INSTANCE
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
Callback to signal completion of thePublisherSource
for thisSubscriber
.void
onError(java.lang.Throwable t)
Callback to receive anerror
for thisSubscriber
.void
onNext(java.lang.Object obj)
Callback to receive adata
element for thisSubscriber
.void
onSubscribe(PublisherSource.Subscription s)
Callback to receive aPublisherSource.Subscription
for thisSubscriber
.
-
-
-
Field Detail
-
INSTANCE
public static final CancelImmediatelySubscriber INSTANCE
-
-
Method Detail
-
onSubscribe
public void onSubscribe(PublisherSource.Subscription s)
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<java.lang.Object>
- Parameters:
s
-PublisherSource.Subscription
for thisSubscriber
.
-
onNext
public void onNext(java.lang.Object obj)
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<java.lang.Object>
- Parameters:
obj
- Adata
element.
-
onError
public void onError(java.lang.Throwable t)
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<java.lang.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<java.lang.Object>
-
-