Class CancelledSubscriber<T>
java.lang.Object
software.amazon.awssdk.http.nio.netty.internal.nrs.CancelledSubscriber<T>
- All Implemented Interfaces:
org.reactivestreams.Subscriber<T>
public final class CancelledSubscriber<T>
extends Object
implements org.reactivestreams.Subscriber<T>
A cancelled subscriber.
This class contains source imported from https://github.com/playframework/netty-reactive-streams,
licensed under the Apache License 2.0, available at the time of the fork (1/31/2020) here:
https://github.com/playframework/netty-reactive-streams/blob/master/LICENSE.txt
All original source licensed under the Apache License 2.0 by playframework. All modifications are
licensed under the Apache License 2.0 by Amazon Web Services.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
void
void
void
onSubscribe
(org.reactivestreams.Subscription subscription)
-
Constructor Details
-
CancelledSubscriber
public CancelledSubscriber()
-
-
Method Details
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription subscription) - Specified by:
onSubscribe
in interfaceorg.reactivestreams.Subscriber<T>
-
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<T>
-
onError
- Specified by:
onError
in interfaceorg.reactivestreams.Subscriber<T>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceorg.reactivestreams.Subscriber<T>
-