Class MappingSubscriber<T,U>
java.lang.Object
software.amazon.awssdk.utils.internal.MappingSubscriber<T,U>
- All Implemented Interfaces:
org.reactivestreams.Subscriber<T>
Maps a subscriber of one type to another type. If an exception is thrown by the mapping function itself, the error
will be propagated to the downstream subscriber as if it had come from the publisher and then the subscription will
be implicitly cancelled and no further events from the publisher will be passed along.
-
Method Summary
Modifier and TypeMethodDescriptionstatic <T,
U> MappingSubscriber <T, U> void
void
void
void
onSubscribe
(org.reactivestreams.Subscription subscription)
-
Method Details
-
create
public static <T,U> MappingSubscriber<T,U> create(org.reactivestreams.Subscriber<? super U> subscriber, Function<T, U> mapFunction) -
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription subscription) - Specified by:
onSubscribe
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>
-
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<T>
-